/*      */ package dm.jdbc.driver;
/*      */ 
/*      */ import dm.jdbc.dbaccess.DBError;
/*      */ import dm.jdbc.dbaccess.DbAccess;
/*      */ import dm.jdbc.dbaccess.DmMsgRecv;
/*      */ import dm.jdbc.dbaccess.DmMsgSend;
/*      */ import dm.jdbc.dbaccess.Request_Response;
/*      */ import dm.jdbc.desc.ParameterDesc;
/*      */ import java.io.IOException;
/*      */ import java.sql.SQLException;
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ public class DmdbCSI
/*      */ {
/*      */   private static void startupServer(DmMsgSend msg, DmdbConnection_bs conn, boolean toPrimary)
/*      */     throws IOException, SQLException
/*      */   {
/*   56 */     Request_Response.req_startup(msg, conn, toPrimary);
/*      */     
/*   58 */     DmMsgRecv recvMsg = access_without_switch(msg, conn);
/*      */     
/*   60 */     Request_Response.resp_startup(recvMsg, conn, toPrimary);
/*      */     
/*      */ 
/*   63 */     conn.getDbAccess().setCompress(conn.getComprMsg());
/*      */     
/*   65 */     if (conn.getEncryptMsg() == 2) {
/*   66 */       conn.getDbAccess().tryEnableSSL(false);
/*   67 */     } else if (conn.getEncryptMsg() == 1) {
/*   68 */       conn.getDbAccess().tryEnableSSL(true);
/*      */     } else {}
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static final void login(DmMsgSend msg, DmdbConnection_bs conn, boolean toPrimary)
/*      */     throws SQLException, IOException
/*      */   {
/*   86 */     Request_Response.req_login(msg, conn, toPrimary);
/*      */     
/*   88 */     DmMsgRecv recvMsg = access_without_switch(msg, conn);
/*      */     
/*   90 */     Request_Response.resp_login(recvMsg, conn);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   public static final void connToServer(DmdbConnection_bs conn)
/*      */     throws SQLException, IOException
/*      */   {
/*      */     try
/*      */     {
/*  105 */       connToServerTry(conn, true);
/*      */       
/*  107 */       if (!conn.hasOneSvr()) {
/*  108 */         conn.getDbSwitch().loginSuccSwitch();
/*      */       }
/*      */     }
/*      */     catch (IOException e) {
/*  112 */       if (!conn.hasOneSvr()) {
/*  113 */         conn.getDbSwitch().loginFailedSwitch();
/*      */       } else {
/*  115 */         DBError.throwSQLException(6001);
/*      */       }
/*      */     }
/*      */     
/*  119 */     connToStandby(conn);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */   public static final void connToStandby(DmdbConnection_bs conn)
/*      */     throws IOException, SQLException
/*      */   {
/*  127 */     if ((conn.getStandbyHost() != null) && (conn.getStandbyHost().length() != 0))
/*      */     {
/*  129 */       conn.getDbAccess().addStandby();
/*      */       
/*      */ 
/*      */ 
/*  133 */       connToServerTry(conn, false);
/*      */       
/*  135 */       conn.setRwSeparate(true);
/*      */     }
/*      */     else
/*      */     {
/*  139 */       conn.setRwSeparate(false);
/*      */     }
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   public static final void connToServerTry(DmdbConnection_bs conn, boolean toPrimary)
/*      */     throws IOException, SQLException
/*      */   {
/*  155 */     DmMsgSend msg = new DmMsgSend();
/*  156 */     startupServer(msg, conn, toPrimary);
/*  157 */     login(msg, conn, toPrimary);
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final int allocStmtHandle(DmdbStatement_bs stmt)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore_1
/*      */     //   2: aconst_null
/*      */     //   3: astore_2
/*      */     //   4: iconst_0
/*      */     //   5: istore_3
/*      */     //   6: aload_0
/*      */     //   7: invokevirtual 129	dm/jdbc/driver/DmdbStatement_bs:getConnection_bs	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   10: astore 4
/*      */     //   12: aload 4
/*      */     //   14: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   17: astore 5
/*      */     //   19: aload 5
/*      */     //   21: invokestatic 139	dm/jdbc/dbaccess/Request_Response:req_stmt_alloc	(Ldm/jdbc/dbaccess/DmMsgSend;)V
/*      */     //   24: aload 5
/*      */     //   26: aload 4
/*      */     //   28: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   31: astore_1
/*      */     //   32: aload_1
/*      */     //   33: aload_0
/*      */     //   34: invokestatic 146	dm/jdbc/dbaccess/Request_Response:resp_stmt_alloc	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbStatement_bs;)I
/*      */     //   37: istore_3
/*      */     //   38: aload 4
/*      */     //   40: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   43: ifeq +80 -> 123
/*      */     //   46: aload 5
/*      */     //   48: aload 4
/*      */     //   50: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   53: astore_2
/*      */     //   54: aload_2
/*      */     //   55: ifnull +68 -> 123
/*      */     //   58: iload_3
/*      */     //   59: aload_2
/*      */     //   60: aload_0
/*      */     //   61: invokestatic 146	dm/jdbc/dbaccess/Request_Response:resp_stmt_alloc	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbStatement_bs;)I
/*      */     //   64: if_icmpeq +59 -> 123
/*      */     //   67: getstatic 156	dm/jdbc/dbaccess/Const:res	Ljava/util/ResourceBundle;
/*      */     //   70: ldc -94
/*      */     //   72: invokevirtual 164	java/util/ResourceBundle:getString	(Ljava/lang/String;)Ljava/lang/String;
/*      */     //   75: invokestatic 170	dm/jdbc/dbaccess/DBError:throwSQLException	(Ljava/lang/String;)V
/*      */     //   78: goto +45 -> 123
/*      */     //   81: astore 5
/*      */     //   83: aload 4
/*      */     //   85: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   88: ifeq +11 -> 99
/*      */     //   91: aload 4
/*      */     //   93: invokevirtual 34	dm/jdbc/driver/DmdbConnection_bs:getDbAccess	()Ldm/jdbc/dbaccess/DbAccess;
/*      */     //   96: invokevirtual 173	dm/jdbc/dbaccess/DbAccess:close	()V
/*      */     //   99: sipush 6001
/*      */     //   102: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   105: aload 4
/*      */     //   107: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   110: goto +18 -> 128
/*      */     //   113: astore 6
/*      */     //   115: aload 4
/*      */     //   117: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   120: aload 6
/*      */     //   122: athrow
/*      */     //   123: aload 4
/*      */     //   125: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   128: iload_3
/*      */     //   129: ireturn
/*      */     // Line number table:
/*      */     //   Java source line #170	-> byte code offset #0
/*      */     //   Java source line #171	-> byte code offset #2
/*      */     //   Java source line #172	-> byte code offset #4
/*      */     //   Java source line #173	-> byte code offset #6
/*      */     //   Java source line #175	-> byte code offset #12
/*      */     //   Java source line #176	-> byte code offset #19
/*      */     //   Java source line #178	-> byte code offset #24
/*      */     //   Java source line #179	-> byte code offset #32
/*      */     //   Java source line #181	-> byte code offset #38
/*      */     //   Java source line #182	-> byte code offset #46
/*      */     //   Java source line #183	-> byte code offset #54
/*      */     //   Java source line #184	-> byte code offset #58
/*      */     //   Java source line #185	-> byte code offset #60
/*      */     //   Java source line #184	-> byte code offset #61
/*      */     //   Java source line #186	-> byte code offset #67
/*      */     //   Java source line #187	-> byte code offset #70
/*      */     //   Java source line #186	-> byte code offset #75
/*      */     //   Java source line #191	-> byte code offset #78
/*      */     //   Java source line #192	-> byte code offset #83
/*      */     //   Java source line #193	-> byte code offset #91
/*      */     //   Java source line #195	-> byte code offset #99
/*      */     //   Java source line #197	-> byte code offset #105
/*      */     //   Java source line #196	-> byte code offset #113
/*      */     //   Java source line #197	-> byte code offset #115
/*      */     //   Java source line #198	-> byte code offset #120
/*      */     //   Java source line #197	-> byte code offset #123
/*      */     //   Java source line #200	-> byte code offset #128
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	130	0	stmt	DmdbStatement_bs
/*      */     //   1	32	1	recvMsg	DmMsgRecv
/*      */     //   3	57	2	recvMsgS	DmMsgRecv
/*      */     //   5	124	3	handle	int
/*      */     //   10	114	4	conn	DmdbConnection_bs
/*      */     //   17	30	5	msg	DmMsgSend
/*      */     //   81	3	5	e	IOException
/*      */     //   113	8	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   12	78	81	java/io/IOException
/*      */     //   12	105	113	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final DmMsgRecv sendCurPosInfo(DmdbStatement_bs stmt, long curPos)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_3
/*      */     //   8: aconst_null
/*      */     //   9: astore 4
/*      */     //   11: new 120	dm/jdbc/dbaccess/DmMsgSend
/*      */     //   14: dup
/*      */     //   15: invokespecial 122	dm/jdbc/dbaccess/DmMsgSend:<init>	()V
/*      */     //   18: astore 5
/*      */     //   20: iconst_0
/*      */     //   21: aload 5
/*      */     //   23: aload_0
/*      */     //   24: lload_1
/*      */     //   25: invokestatic 190	dm/jdbc/dbaccess/Request_Response:req_execute_sendCurInfo	(ZLdm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbStatement_bs;J)V
/*      */     //   28: aload 5
/*      */     //   30: aload_3
/*      */     //   31: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   34: astore 4
/*      */     //   36: goto +27 -> 63
/*      */     //   39: astore 5
/*      */     //   41: sipush 6001
/*      */     //   44: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   47: aload_3
/*      */     //   48: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   51: goto +16 -> 67
/*      */     //   54: astore 6
/*      */     //   56: aload_3
/*      */     //   57: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   60: aload 6
/*      */     //   62: athrow
/*      */     //   63: aload_3
/*      */     //   64: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   67: aload 4
/*      */     //   69: aload_0
/*      */     //   70: invokestatic 197	dm/jdbc/dbaccess/Request_Response:resp_execute	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbStatement_bs;)Ldm/jdbc/driver/DmdbInfo;
/*      */     //   73: pop
/*      */     //   74: aload 4
/*      */     //   76: areturn
/*      */     // Line number table:
/*      */     //   Java source line #216	-> byte code offset #0
/*      */     //   Java source line #218	-> byte code offset #8
/*      */     //   Java source line #220	-> byte code offset #11
/*      */     //   Java source line #221	-> byte code offset #20
/*      */     //   Java source line #222	-> byte code offset #28
/*      */     //   Java source line #223	-> byte code offset #36
/*      */     //   Java source line #224	-> byte code offset #41
/*      */     //   Java source line #226	-> byte code offset #47
/*      */     //   Java source line #225	-> byte code offset #54
/*      */     //   Java source line #226	-> byte code offset #56
/*      */     //   Java source line #227	-> byte code offset #60
/*      */     //   Java source line #226	-> byte code offset #63
/*      */     //   Java source line #229	-> byte code offset #67
/*      */     //   Java source line #231	-> byte code offset #74
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	77	0	stmt	DmdbStatement_bs
/*      */     //   0	77	1	curPos	long
/*      */     //   7	57	3	conn	DmdbConnection_bs
/*      */     //   9	66	4	recvMsg	DmMsgRecv
/*      */     //   18	11	5	msg	DmMsgSend
/*      */     //   39	3	5	e	IOException
/*      */     //   54	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   11	36	39	java/io/IOException
/*      */     //   11	47	54	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final void closeHandle(DmdbStatement_bs stmt)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_1
/*      */     //   8: aconst_null
/*      */     //   9: astore_2
/*      */     //   10: aload_1
/*      */     //   11: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   14: astore_3
/*      */     //   15: aload_3
/*      */     //   16: aload_0
/*      */     //   17: invokevirtual 205	dm/jdbc/driver/DmdbStatement_bs:getHandle	()I
/*      */     //   20: invokestatic 208	dm/jdbc/dbaccess/Request_Response:req_close_stmt	(Ldm/jdbc/dbaccess/DmMsgSend;I)V
/*      */     //   23: aload_3
/*      */     //   24: aload_1
/*      */     //   25: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   28: astore_2
/*      */     //   29: goto +26 -> 55
/*      */     //   32: astore_3
/*      */     //   33: sipush 6001
/*      */     //   36: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   39: aload_1
/*      */     //   40: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   43: goto +16 -> 59
/*      */     //   46: astore 4
/*      */     //   48: aload_1
/*      */     //   49: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   52: aload 4
/*      */     //   54: athrow
/*      */     //   55: aload_1
/*      */     //   56: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   59: aload_2
/*      */     //   60: aload_1
/*      */     //   61: invokestatic 212	dm/jdbc/dbaccess/Request_Response:resp_close_stmt	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)V
/*      */     //   64: return
/*      */     // Line number table:
/*      */     //   Java source line #244	-> byte code offset #0
/*      */     //   Java source line #246	-> byte code offset #8
/*      */     //   Java source line #248	-> byte code offset #10
/*      */     //   Java source line #249	-> byte code offset #15
/*      */     //   Java source line #250	-> byte code offset #23
/*      */     //   Java source line #251	-> byte code offset #29
/*      */     //   Java source line #252	-> byte code offset #33
/*      */     //   Java source line #254	-> byte code offset #39
/*      */     //   Java source line #253	-> byte code offset #46
/*      */     //   Java source line #254	-> byte code offset #48
/*      */     //   Java source line #255	-> byte code offset #52
/*      */     //   Java source line #254	-> byte code offset #55
/*      */     //   Java source line #257	-> byte code offset #59
/*      */     //   Java source line #258	-> byte code offset #64
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	65	0	stmt	DmdbStatement_bs
/*      */     //   7	54	1	conn	DmdbConnection_bs
/*      */     //   9	51	2	recvMsg	DmMsgRecv
/*      */     //   14	10	3	msg	DmMsgSend
/*      */     //   32	2	3	e	IOException
/*      */     //   46	7	4	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   10	29	32	java/io/IOException
/*      */     //   10	39	46	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final void freeHandle(DmdbStatement_bs stmt)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_1
/*      */     //   8: aconst_null
/*      */     //   9: astore_2
/*      */     //   10: aconst_null
/*      */     //   11: astore_3
/*      */     //   12: aload_1
/*      */     //   13: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   16: astore 4
/*      */     //   18: aload 4
/*      */     //   20: aload_0
/*      */     //   21: invokevirtual 205	dm/jdbc/driver/DmdbStatement_bs:getHandle	()I
/*      */     //   24: invokestatic 216	dm/jdbc/dbaccess/Request_Response:req_stmt_free	(Ldm/jdbc/dbaccess/DmMsgSend;I)V
/*      */     //   27: aload 4
/*      */     //   29: aload_1
/*      */     //   30: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   33: astore_2
/*      */     //   34: aload_2
/*      */     //   35: aload_1
/*      */     //   36: invokestatic 219	dm/jdbc/dbaccess/Request_Response:resp_stmt_free	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)V
/*      */     //   39: aload_1
/*      */     //   40: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   43: ifeq +60 -> 103
/*      */     //   46: aload 4
/*      */     //   48: aload_1
/*      */     //   49: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   52: astore_3
/*      */     //   53: aload_3
/*      */     //   54: ifnull +49 -> 103
/*      */     //   57: aload_3
/*      */     //   58: aload_1
/*      */     //   59: invokestatic 219	dm/jdbc/dbaccess/Request_Response:resp_stmt_free	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)V
/*      */     //   62: goto +41 -> 103
/*      */     //   65: astore 4
/*      */     //   67: aload_1
/*      */     //   68: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   71: ifeq +10 -> 81
/*      */     //   74: aload_1
/*      */     //   75: invokevirtual 34	dm/jdbc/driver/DmdbConnection_bs:getDbAccess	()Ldm/jdbc/dbaccess/DbAccess;
/*      */     //   78: invokevirtual 173	dm/jdbc/dbaccess/DbAccess:close	()V
/*      */     //   81: sipush 6001
/*      */     //   84: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   87: aload_1
/*      */     //   88: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   91: goto +16 -> 107
/*      */     //   94: astore 5
/*      */     //   96: aload_1
/*      */     //   97: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   100: aload 5
/*      */     //   102: athrow
/*      */     //   103: aload_1
/*      */     //   104: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   107: return
/*      */     // Line number table:
/*      */     //   Java source line #270	-> byte code offset #0
/*      */     //   Java source line #272	-> byte code offset #8
/*      */     //   Java source line #273	-> byte code offset #10
/*      */     //   Java source line #275	-> byte code offset #12
/*      */     //   Java source line #276	-> byte code offset #18
/*      */     //   Java source line #278	-> byte code offset #27
/*      */     //   Java source line #279	-> byte code offset #34
/*      */     //   Java source line #281	-> byte code offset #39
/*      */     //   Java source line #282	-> byte code offset #46
/*      */     //   Java source line #283	-> byte code offset #53
/*      */     //   Java source line #284	-> byte code offset #57
/*      */     //   Java source line #286	-> byte code offset #62
/*      */     //   Java source line #287	-> byte code offset #67
/*      */     //   Java source line #288	-> byte code offset #74
/*      */     //   Java source line #290	-> byte code offset #81
/*      */     //   Java source line #292	-> byte code offset #87
/*      */     //   Java source line #291	-> byte code offset #94
/*      */     //   Java source line #292	-> byte code offset #96
/*      */     //   Java source line #293	-> byte code offset #100
/*      */     //   Java source line #292	-> byte code offset #103
/*      */     //   Java source line #296	-> byte code offset #107
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	108	0	stmt	DmdbStatement_bs
/*      */     //   7	97	1	conn	DmdbConnection_bs
/*      */     //   9	26	2	recvMsg	DmMsgRecv
/*      */     //   11	47	3	recvMsgS	DmMsgRecv
/*      */     //   16	31	4	msg	DmMsgSend
/*      */     //   65	3	4	e	IOException
/*      */     //   94	7	5	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   12	62	65	java/io/IOException
/*      */     //   12	87	94	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final DmdbInfo prepareSQL(DmdbStatement_bs stmt, String sql, boolean direct, int checkFlag)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore 4
/*      */     //   9: aconst_null
/*      */     //   10: astore 5
/*      */     //   12: aconst_null
/*      */     //   13: astore 6
/*      */     //   15: aload 4
/*      */     //   17: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   20: astore 7
/*      */     //   22: aload 7
/*      */     //   24: aload_0
/*      */     //   25: aload_1
/*      */     //   26: iload_2
/*      */     //   27: iload_3
/*      */     //   28: invokestatic 224	dm/jdbc/dbaccess/Request_Response:req_prepare	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbStatement_bs;Ljava/lang/String;ZI)V
/*      */     //   31: aload 7
/*      */     //   33: aload 4
/*      */     //   35: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   38: astore 5
/*      */     //   40: aload 5
/*      */     //   42: invokevirtual 228	dm/jdbc/dbaccess/DmMsgRecv:getFromStandby	()Z
/*      */     //   45: istore 8
/*      */     //   47: aload_0
/*      */     //   48: iload 8
/*      */     //   50: invokevirtual 233	dm/jdbc/driver/DmdbStatement_bs:setFromStandby	(Z)V
/*      */     //   53: aload 5
/*      */     //   55: aload 4
/*      */     //   57: invokevirtual 236	dm/jdbc/driver/DmdbConnection_bs:getServerEncoding	()Ljava/lang/String;
/*      */     //   60: aload_0
/*      */     //   61: iload_2
/*      */     //   62: invokestatic 239	dm/jdbc/dbaccess/Request_Response:resp_prepare	(Ldm/jdbc/dbaccess/DmMsgRecv;Ljava/lang/String;Ldm/jdbc/driver/DmdbStatement_bs;Z)Ldm/jdbc/driver/DmdbInfo;
/*      */     //   65: astore 6
/*      */     //   67: aload 6
/*      */     //   69: invokevirtual 243	dm/jdbc/driver/DmdbInfo:getSavepointFlag	()Z
/*      */     //   72: ifeq +66 -> 138
/*      */     //   75: aload 4
/*      */     //   77: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   80: ifeq +58 -> 138
/*      */     //   83: iload 8
/*      */     //   85: ifeq +15 -> 100
/*      */     //   88: aload 7
/*      */     //   90: aload 4
/*      */     //   92: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   95: astore 5
/*      */     //   97: goto +41 -> 138
/*      */     //   100: aload 7
/*      */     //   102: aload 4
/*      */     //   104: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   107: astore 5
/*      */     //   109: goto +29 -> 138
/*      */     //   112: astore 7
/*      */     //   114: sipush 6001
/*      */     //   117: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   120: aload 4
/*      */     //   122: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   125: goto +18 -> 143
/*      */     //   128: astore 9
/*      */     //   130: aload 4
/*      */     //   132: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   135: aload 9
/*      */     //   137: athrow
/*      */     //   138: aload 4
/*      */     //   140: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   143: aload 6
/*      */     //   145: areturn
/*      */     // Line number table:
/*      */     //   Java source line #313	-> byte code offset #0
/*      */     //   Java source line #315	-> byte code offset #9
/*      */     //   Java source line #316	-> byte code offset #12
/*      */     //   Java source line #318	-> byte code offset #15
/*      */     //   Java source line #319	-> byte code offset #22
/*      */     //   Java source line #320	-> byte code offset #31
/*      */     //   Java source line #322	-> byte code offset #40
/*      */     //   Java source line #323	-> byte code offset #47
/*      */     //   Java source line #325	-> byte code offset #53
/*      */     //   Java source line #326	-> byte code offset #55
/*      */     //   Java source line #325	-> byte code offset #62
/*      */     //   Java source line #328	-> byte code offset #67
/*      */     //   Java source line #329	-> byte code offset #83
/*      */     //   Java source line #331	-> byte code offset #88
/*      */     //   Java source line #332	-> byte code offset #97
/*      */     //   Java source line #335	-> byte code offset #100
/*      */     //   Java source line #339	-> byte code offset #109
/*      */     //   Java source line #340	-> byte code offset #114
/*      */     //   Java source line #342	-> byte code offset #120
/*      */     //   Java source line #341	-> byte code offset #128
/*      */     //   Java source line #342	-> byte code offset #130
/*      */     //   Java source line #343	-> byte code offset #135
/*      */     //   Java source line #342	-> byte code offset #138
/*      */     //   Java source line #345	-> byte code offset #143
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	146	0	stmt	DmdbStatement_bs
/*      */     //   0	146	1	sql	String
/*      */     //   0	146	2	direct	boolean
/*      */     //   0	146	3	checkFlag	int
/*      */     //   7	132	4	conn	DmdbConnection_bs
/*      */     //   10	98	5	recvMsg	DmMsgRecv
/*      */     //   13	131	6	dbInfo	DmdbInfo
/*      */     //   20	81	7	msg	DmMsgSend
/*      */     //   112	3	7	e	IOException
/*      */     //   45	39	8	fromStandby	boolean
/*      */     //   128	8	9	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   15	109	112	java/io/IOException
/*      */     //   15	120	128	finally
/*      */   }
/*      */   
/*      */   public static final DmdbInfo prepareSQLForRe(DmdbStatement_bs stmt, String sql, boolean direct, int checkFlag, DmMsgSend msg, boolean toStandby)
/*      */     throws SQLException
/*      */   {
/*  351 */     DmdbConnection_bs conn = (DmdbConnection_bs)stmt.getConnection();
/*      */     
/*  353 */     DmMsgRecv recvMsg = null;
/*      */     try {
/*  355 */       Request_Response.req_prepare(msg, stmt, sql, direct, checkFlag);
/*      */       
/*  357 */       if (toStandby)
/*      */       {
/*  359 */         recvMsg = accessToStandby(msg, conn);
/*      */       }
/*      */       else
/*      */       {
/*  363 */         recvMsg = accessToPrimary(msg, conn);
/*      */       }
/*      */     } catch (IOException e) {
/*  366 */       DBError.throwSQLException(6001);
/*      */     }
/*      */     
/*      */ 
/*  370 */     return Request_Response.resp_prepare(recvMsg, conn.getServerEncoding(), 
/*  371 */       stmt, direct);
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final DmdbInfo directExec_Opt(DmdbStatement_bs stmt, dm.jdbc.innerData.DmdbExecOpt execOpt)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_2
/*      */     //   8: aconst_null
/*      */     //   9: astore_3
/*      */     //   10: aconst_null
/*      */     //   11: astore 4
/*      */     //   13: aload_2
/*      */     //   14: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   17: astore 5
/*      */     //   19: aload 5
/*      */     //   21: aload_0
/*      */     //   22: aload_1
/*      */     //   23: invokestatic 260	dm/jdbc/dbaccess/Request_Response:req_exec_direct	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbStatement_bs;Ldm/jdbc/innerData/DmdbExecOpt;)V
/*      */     //   26: aload 5
/*      */     //   28: aload_2
/*      */     //   29: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   32: astore_3
/*      */     //   33: aload_3
/*      */     //   34: aload_0
/*      */     //   35: invokestatic 264	dm/jdbc/dbaccess/Request_Response:resp_exec_direct	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbStatement_bs;)Ldm/jdbc/driver/DmdbInfo;
/*      */     //   38: astore 4
/*      */     //   40: aload 4
/*      */     //   42: invokevirtual 243	dm/jdbc/driver/DmdbInfo:getSavepointFlag	()Z
/*      */     //   45: ifeq +61 -> 106
/*      */     //   48: aload_2
/*      */     //   49: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   52: ifeq +54 -> 106
/*      */     //   55: aload_3
/*      */     //   56: invokevirtual 228	dm/jdbc/dbaccess/DmMsgRecv:getFromStandby	()Z
/*      */     //   59: ifeq +13 -> 72
/*      */     //   62: aload 5
/*      */     //   64: aload_2
/*      */     //   65: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   68: pop
/*      */     //   69: goto +37 -> 106
/*      */     //   72: aload 5
/*      */     //   74: aload_2
/*      */     //   75: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   78: pop
/*      */     //   79: goto +27 -> 106
/*      */     //   82: astore 5
/*      */     //   84: sipush 6001
/*      */     //   87: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   90: aload_2
/*      */     //   91: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   94: goto +16 -> 110
/*      */     //   97: astore 6
/*      */     //   99: aload_2
/*      */     //   100: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   103: aload 6
/*      */     //   105: athrow
/*      */     //   106: aload_2
/*      */     //   107: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   110: aload_0
/*      */     //   111: aload_3
/*      */     //   112: invokevirtual 228	dm/jdbc/dbaccess/DmMsgRecv:getFromStandby	()Z
/*      */     //   115: invokevirtual 233	dm/jdbc/driver/DmdbStatement_bs:setFromStandby	(Z)V
/*      */     //   118: aload 4
/*      */     //   120: areturn
/*      */     // Line number table:
/*      */     //   Java source line #386	-> byte code offset #0
/*      */     //   Java source line #388	-> byte code offset #8
/*      */     //   Java source line #389	-> byte code offset #10
/*      */     //   Java source line #391	-> byte code offset #13
/*      */     //   Java source line #392	-> byte code offset #19
/*      */     //   Java source line #393	-> byte code offset #26
/*      */     //   Java source line #394	-> byte code offset #33
/*      */     //   Java source line #395	-> byte code offset #40
/*      */     //   Java source line #397	-> byte code offset #55
/*      */     //   Java source line #399	-> byte code offset #62
/*      */     //   Java source line #400	-> byte code offset #69
/*      */     //   Java source line #403	-> byte code offset #72
/*      */     //   Java source line #406	-> byte code offset #79
/*      */     //   Java source line #407	-> byte code offset #84
/*      */     //   Java source line #409	-> byte code offset #90
/*      */     //   Java source line #408	-> byte code offset #97
/*      */     //   Java source line #409	-> byte code offset #99
/*      */     //   Java source line #410	-> byte code offset #103
/*      */     //   Java source line #409	-> byte code offset #106
/*      */     //   Java source line #412	-> byte code offset #110
/*      */     //   Java source line #413	-> byte code offset #118
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	121	0	stmt	DmdbStatement_bs
/*      */     //   0	121	1	execOpt	dm.jdbc.innerData.DmdbExecOpt
/*      */     //   7	100	2	conn	DmdbConnection_bs
/*      */     //   9	103	3	recv	DmMsgRecv
/*      */     //   11	108	4	dbInfo	DmdbInfo
/*      */     //   17	56	5	msg	DmMsgSend
/*      */     //   82	3	5	e	IOException
/*      */     //   97	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   13	79	82	java/io/IOException
/*      */     //   13	90	97	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final void commitWork(DmdbConnection_bs conn, int holdability)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore_2
/*      */     //   2: aload_0
/*      */     //   3: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   6: astore_3
/*      */     //   7: aload_3
/*      */     //   8: invokestatic 272	dm/jdbc/dbaccess/Request_Response:req_commit	(Ldm/jdbc/dbaccess/DmMsgSend;)V
/*      */     //   11: aload_3
/*      */     //   12: aload_0
/*      */     //   13: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   16: astore_2
/*      */     //   17: aload_0
/*      */     //   18: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   21: ifeq +35 -> 56
/*      */     //   24: aload_3
/*      */     //   25: aload_0
/*      */     //   26: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   29: pop
/*      */     //   30: goto +26 -> 56
/*      */     //   33: astore_3
/*      */     //   34: sipush 6001
/*      */     //   37: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   40: aload_0
/*      */     //   41: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   44: goto +16 -> 60
/*      */     //   47: astore 4
/*      */     //   49: aload_0
/*      */     //   50: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   53: aload 4
/*      */     //   55: athrow
/*      */     //   56: aload_0
/*      */     //   57: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   60: aload_2
/*      */     //   61: aload_0
/*      */     //   62: invokestatic 275	dm/jdbc/dbaccess/Request_Response:resp_commit	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)I
/*      */     //   65: istore_3
/*      */     //   66: iload_3
/*      */     //   67: iflt +12 -> 79
/*      */     //   70: iload_1
/*      */     //   71: iconst_2
/*      */     //   72: if_icmpne +7 -> 79
/*      */     //   75: aload_0
/*      */     //   76: invokevirtual 279	dm/jdbc/driver/DmdbConnection_bs:close_all_resultSet	()V
/*      */     //   79: return
/*      */     // Line number table:
/*      */     //   Java source line #458	-> byte code offset #0
/*      */     //   Java source line #460	-> byte code offset #2
/*      */     //   Java source line #461	-> byte code offset #7
/*      */     //   Java source line #462	-> byte code offset #11
/*      */     //   Java source line #463	-> byte code offset #17
/*      */     //   Java source line #464	-> byte code offset #24
/*      */     //   Java source line #465	-> byte code offset #30
/*      */     //   Java source line #466	-> byte code offset #34
/*      */     //   Java source line #468	-> byte code offset #40
/*      */     //   Java source line #467	-> byte code offset #47
/*      */     //   Java source line #468	-> byte code offset #49
/*      */     //   Java source line #469	-> byte code offset #53
/*      */     //   Java source line #468	-> byte code offset #56
/*      */     //   Java source line #471	-> byte code offset #60
/*      */     //   Java source line #473	-> byte code offset #66
/*      */     //   Java source line #474	-> byte code offset #75
/*      */     //   Java source line #475	-> byte code offset #79
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	80	0	conn	DmdbConnection_bs
/*      */     //   0	80	1	holdability	int
/*      */     //   1	60	2	recvMsg	DmMsgRecv
/*      */     //   6	19	3	msg	DmMsgSend
/*      */     //   33	2	3	e	IOException
/*      */     //   65	2	3	sqlcode	int
/*      */     //   47	7	4	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   2	30	33	java/io/IOException
/*      */     //   2	40	47	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final void rollbackWork(DmdbConnection_bs conn, int holdability)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore_2
/*      */     //   2: aload_0
/*      */     //   3: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   6: astore_3
/*      */     //   7: aload_3
/*      */     //   8: invokestatic 285	dm/jdbc/dbaccess/Request_Response:req_rollback	(Ldm/jdbc/dbaccess/DmMsgSend;)V
/*      */     //   11: aload_3
/*      */     //   12: aload_0
/*      */     //   13: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   16: astore_2
/*      */     //   17: aload_0
/*      */     //   18: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   21: ifeq +35 -> 56
/*      */     //   24: aload_3
/*      */     //   25: aload_0
/*      */     //   26: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   29: pop
/*      */     //   30: goto +26 -> 56
/*      */     //   33: astore_3
/*      */     //   34: sipush 6001
/*      */     //   37: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   40: aload_0
/*      */     //   41: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   44: goto +16 -> 60
/*      */     //   47: astore 4
/*      */     //   49: aload_0
/*      */     //   50: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   53: aload 4
/*      */     //   55: athrow
/*      */     //   56: aload_0
/*      */     //   57: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   60: aload_2
/*      */     //   61: aload_0
/*      */     //   62: invokestatic 288	dm/jdbc/dbaccess/Request_Response:resp_rollback	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)I
/*      */     //   65: istore_3
/*      */     //   66: iload_3
/*      */     //   67: iflt +12 -> 79
/*      */     //   70: iload_1
/*      */     //   71: iconst_2
/*      */     //   72: if_icmpne +7 -> 79
/*      */     //   75: aload_0
/*      */     //   76: invokevirtual 279	dm/jdbc/driver/DmdbConnection_bs:close_all_resultSet	()V
/*      */     //   79: return
/*      */     // Line number table:
/*      */     //   Java source line #488	-> byte code offset #0
/*      */     //   Java source line #490	-> byte code offset #2
/*      */     //   Java source line #491	-> byte code offset #7
/*      */     //   Java source line #492	-> byte code offset #11
/*      */     //   Java source line #493	-> byte code offset #17
/*      */     //   Java source line #494	-> byte code offset #24
/*      */     //   Java source line #495	-> byte code offset #30
/*      */     //   Java source line #496	-> byte code offset #34
/*      */     //   Java source line #498	-> byte code offset #40
/*      */     //   Java source line #497	-> byte code offset #47
/*      */     //   Java source line #498	-> byte code offset #49
/*      */     //   Java source line #499	-> byte code offset #53
/*      */     //   Java source line #498	-> byte code offset #56
/*      */     //   Java source line #501	-> byte code offset #60
/*      */     //   Java source line #503	-> byte code offset #66
/*      */     //   Java source line #504	-> byte code offset #75
/*      */     //   Java source line #505	-> byte code offset #79
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	80	0	conn	DmdbConnection_bs
/*      */     //   0	80	1	holdability	int
/*      */     //   1	60	2	recvMsg	DmMsgRecv
/*      */     //   6	19	3	msg	DmMsgSend
/*      */     //   33	2	3	e	IOException
/*      */     //   65	2	3	sqlcode	int
/*      */     //   47	7	4	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   2	30	33	java/io/IOException
/*      */     //   2	40	47	finally
/*      */   }
/*      */   
/*      */   private static void setParasMsg(boolean preExeced, DmMsgSend msg, DmdbStatement_bs stmt, int irow)
/*      */     throws SQLException
/*      */   {
/*  522 */     Request_Response.req_execute(preExeced, msg, stmt, 
/*  523 */       stmt.cursorUpdateRow, irow);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static int setBatchParasMsg(boolean preExeced, int startRow, DmMsgSend msg, DmdbPreparedStatement_bs stmt)
/*      */     throws SQLException
/*      */   {
/*  544 */     return Request_Response.req_execute_for_batch(preExeced, startRow, msg, 
/*  545 */       stmt);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   public static final DmdbInfo executePrepared(DmdbStatement_bs stmt, int irow)
/*      */     throws SQLException
/*      */   {
/*  563 */     return executePrepared(false, stmt, irow, null);
/*      */   }
/*      */   
/*      */   private static final DmdbInfo executePrepared(boolean preExeced, DmdbStatement_bs stmt, int irow, DmMsgSend sendMsg) throws SQLException
/*      */   {
/*  568 */     DmdbConnection_bs conn = (DmdbConnection_bs)stmt.getConnection();
/*      */     
/*  570 */     DmMsgRecv recv = null;
/*  571 */     DmdbInfo dbInfo = null;
/*  572 */     boolean fromStandby = stmt.getFromStandby();
/*  573 */     DmMsgSend msg = null;
/*      */     try
/*      */     {
/*  576 */       if (sendMsg == null)
/*      */       {
/*  578 */         msg = conn.getMsg();
/*      */       }
/*      */       else
/*      */       {
/*  582 */         msg = sendMsg;
/*      */       }
/*  584 */       setParasMsg(preExeced, msg, stmt, irow);
/*  585 */       recv = access_server(msg, conn);
/*      */       
/*  587 */       stmt.setPutLobData(1);
/*      */       try {
/*  589 */         dbInfo = getDescAndResultSet(stmt, recv);
/*  590 */         if ((dbInfo.getSavepointFlag()) && (conn.checkHasStandby()))
/*      */         {
/*  592 */           if (recv.getFromStandby())
/*      */           {
/*  594 */             accessToPrimary(msg, conn);
/*      */           }
/*      */           else
/*      */           {
/*  598 */             accessToStandby(msg, conn);
/*      */           }
/*      */         }
/*      */       } catch (SQLException ex) {
/*  602 */         if ((ex.getErrorCode() == 63534) && (conn.checkHasStandby())) {
/*  603 */           prepareSQLForRe(stmt, stmt.originalSql, false, 
/*  604 */             0, msg, !fromStandby);
/*      */           
/*      */ 
/*  607 */           setParasMsg(preExeced, msg, stmt, irow);
/*      */           try {
/*  609 */             recv = access_server(msg, conn);
/*      */           } catch (IOException e) {
/*  611 */             DBError.throwSQLException(6001);
/*      */           }
/*      */           
/*  614 */           dbInfo = getDescAndResultSet(stmt, recv);
/*      */         } else {
/*  616 */           throw ex;
/*      */         }
/*  618 */       } } catch (IOException e) { e = e;
/*  619 */       DBError.throwSQLException(6001);
/*      */       
/*  621 */       if (sendMsg != null)
/*      */         break label246;
/*  623 */       conn.returnMsg();
/*      */       break label246;
/*      */     }
/*      */     finally
/*      */     {
/*  620 */       localObject = 
/*      */       
/*      */ 
/*  623 */         finally;
/*  621 */       if (sendMsg == null)
/*      */       {
/*  623 */         conn.returnMsg();
/*      */       }
/*  625 */       throw ((Throwable)localObject);
/*      */     }
/*  621 */     if (sendMsg == null)
/*      */     {
/*  623 */       conn.returnMsg();
/*      */     }
/*      */     
/*      */     label246:
/*  627 */     stmt.setFromStandby(recv.getFromStandby());
/*      */     
/*  629 */     return dbInfo;
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final int[] executePreparedBatch(DmdbPreparedStatement_bs stmt)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 337	dm/jdbc/driver/DmdbPreparedStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_1
/*      */     //   8: aload_0
/*      */     //   9: invokevirtual 340	dm/jdbc/driver/DmdbPreparedStatement_bs:getBatchSize	()I
/*      */     //   12: istore_2
/*      */     //   13: iload_2
/*      */     //   14: newarray <illegal type>
/*      */     //   16: astore_3
/*      */     //   17: aconst_null
/*      */     //   18: astore 4
/*      */     //   20: iconst_0
/*      */     //   21: istore 5
/*      */     //   23: aconst_null
/*      */     //   24: astore 6
/*      */     //   26: aload_1
/*      */     //   27: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   30: astore 7
/*      */     //   32: iconst_0
/*      */     //   33: istore 8
/*      */     //   35: iconst_0
/*      */     //   36: istore 9
/*      */     //   38: goto +119 -> 157
/*      */     //   41: iload 5
/*      */     //   43: iload 8
/*      */     //   45: aload 7
/*      */     //   47: aload_0
/*      */     //   48: invokestatic 343	dm/jdbc/driver/DmdbCSI:setBatchParasMsg	(ZILdm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbPreparedStatement_bs;)I
/*      */     //   51: istore 9
/*      */     //   53: iload 9
/*      */     //   55: iload 8
/*      */     //   57: if_icmpeq +38 -> 95
/*      */     //   60: aload 7
/*      */     //   62: aload_1
/*      */     //   63: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   66: astore 6
/*      */     //   68: aload 6
/*      */     //   70: aload_0
/*      */     //   71: invokestatic 345	dm/jdbc/driver/DmdbCSI:getBatchRowCounts	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbStatement_bs;)[I
/*      */     //   74: astore 4
/*      */     //   76: aload 4
/*      */     //   78: ifnull +17 -> 95
/*      */     //   81: aload 4
/*      */     //   83: iconst_0
/*      */     //   84: aload_3
/*      */     //   85: iload 8
/*      */     //   87: iload 9
/*      */     //   89: iload 8
/*      */     //   91: isub
/*      */     //   92: invokestatic 349	java/lang/System:arraycopy	(Ljava/lang/Object;ILjava/lang/Object;II)V
/*      */     //   95: iload 9
/*      */     //   97: iload_2
/*      */     //   98: if_icmpne +6 -> 104
/*      */     //   101: goto +89 -> 190
/*      */     //   104: iload 5
/*      */     //   106: aload_0
/*      */     //   107: iload 9
/*      */     //   109: aload 7
/*      */     //   111: invokestatic 311	dm/jdbc/driver/DmdbCSI:executePrepared	(ZLdm/jdbc/driver/DmdbStatement_bs;ILdm/jdbc/dbaccess/DmMsgSend;)Ldm/jdbc/driver/DmdbInfo;
/*      */     //   114: astore 10
/*      */     //   116: iconst_1
/*      */     //   117: istore 5
/*      */     //   119: aload 10
/*      */     //   121: invokevirtual 355	dm/jdbc/driver/DmdbInfo:getRowCount	()J
/*      */     //   124: ldc2_w 359
/*      */     //   127: lcmp
/*      */     //   128: ifle +13 -> 141
/*      */     //   131: aload_3
/*      */     //   132: iload 9
/*      */     //   134: ldc_w 361
/*      */     //   137: iastore
/*      */     //   138: goto +13 -> 151
/*      */     //   141: aload_3
/*      */     //   142: iload 9
/*      */     //   144: aload 10
/*      */     //   146: invokevirtual 355	dm/jdbc/driver/DmdbInfo:getRowCount	()J
/*      */     //   149: l2i
/*      */     //   150: iastore
/*      */     //   151: iload 9
/*      */     //   153: iconst_1
/*      */     //   154: iadd
/*      */     //   155: istore 8
/*      */     //   157: iload 8
/*      */     //   159: iload_2
/*      */     //   160: if_icmplt -119 -> 41
/*      */     //   163: goto +27 -> 190
/*      */     //   166: astore 7
/*      */     //   168: sipush 6001
/*      */     //   171: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   174: aload_1
/*      */     //   175: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   178: goto +16 -> 194
/*      */     //   181: astore 11
/*      */     //   183: aload_1
/*      */     //   184: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   187: aload 11
/*      */     //   189: athrow
/*      */     //   190: aload_1
/*      */     //   191: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   194: aload 6
/*      */     //   196: ifnull +12 -> 208
/*      */     //   199: aload_0
/*      */     //   200: aload 6
/*      */     //   202: invokevirtual 228	dm/jdbc/dbaccess/DmMsgRecv:getFromStandby	()Z
/*      */     //   205: invokevirtual 362	dm/jdbc/driver/DmdbPreparedStatement_bs:setFromStandby	(Z)V
/*      */     //   208: aload_3
/*      */     //   209: areturn
/*      */     // Line number table:
/*      */     //   Java source line #648	-> byte code offset #0
/*      */     //   Java source line #649	-> byte code offset #8
/*      */     //   Java source line #650	-> byte code offset #13
/*      */     //   Java source line #651	-> byte code offset #17
/*      */     //   Java source line #652	-> byte code offset #20
/*      */     //   Java source line #654	-> byte code offset #23
/*      */     //   Java source line #656	-> byte code offset #26
/*      */     //   Java source line #657	-> byte code offset #32
/*      */     //   Java source line #658	-> byte code offset #35
/*      */     //   Java source line #659	-> byte code offset #38
/*      */     //   Java source line #660	-> byte code offset #41
/*      */     //   Java source line #663	-> byte code offset #53
/*      */     //   Java source line #664	-> byte code offset #60
/*      */     //   Java source line #665	-> byte code offset #68
/*      */     //   Java source line #666	-> byte code offset #76
/*      */     //   Java source line #667	-> byte code offset #81
/*      */     //   Java source line #668	-> byte code offset #89
/*      */     //   Java source line #667	-> byte code offset #92
/*      */     //   Java source line #671	-> byte code offset #95
/*      */     //   Java source line #672	-> byte code offset #101
/*      */     //   Java source line #675	-> byte code offset #104
/*      */     //   Java source line #678	-> byte code offset #116
/*      */     //   Java source line #679	-> byte code offset #119
/*      */     //   Java source line #680	-> byte code offset #131
/*      */     //   Java source line #681	-> byte code offset #138
/*      */     //   Java source line #682	-> byte code offset #141
/*      */     //   Java source line #686	-> byte code offset #151
/*      */     //   Java source line #659	-> byte code offset #157
/*      */     //   Java source line #688	-> byte code offset #163
/*      */     //   Java source line #689	-> byte code offset #168
/*      */     //   Java source line #691	-> byte code offset #174
/*      */     //   Java source line #690	-> byte code offset #181
/*      */     //   Java source line #691	-> byte code offset #183
/*      */     //   Java source line #692	-> byte code offset #187
/*      */     //   Java source line #691	-> byte code offset #190
/*      */     //   Java source line #694	-> byte code offset #194
/*      */     //   Java source line #695	-> byte code offset #199
/*      */     //   Java source line #698	-> byte code offset #208
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	210	0	stmt	DmdbPreparedStatement_bs
/*      */     //   7	184	1	conn	DmdbConnection_bs
/*      */     //   12	148	2	batchSize	int
/*      */     //   16	193	3	retArr	int[]
/*      */     //   18	64	4	retTmp	int[]
/*      */     //   21	97	5	preExeced	boolean
/*      */     //   24	177	6	recv	DmMsgRecv
/*      */     //   30	80	7	msg	DmMsgSend
/*      */     //   166	3	7	e	IOException
/*      */     //   33	125	8	startRow	int
/*      */     //   36	116	9	nextRow	int
/*      */     //   114	31	10	retdbInfo	DmdbInfo
/*      */     //   181	7	11	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   26	163	166	java/io/IOException
/*      */     //   26	174	181	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final DmdbInfo getMoreResult(DmdbStatement_bs stmt, short resId)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_2
/*      */     //   8: aconst_null
/*      */     //   9: astore_3
/*      */     //   10: aload_2
/*      */     //   11: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   14: astore 4
/*      */     //   16: aload 4
/*      */     //   18: aload_0
/*      */     //   19: invokevirtual 205	dm/jdbc/driver/DmdbStatement_bs:getHandle	()I
/*      */     //   22: iload_1
/*      */     //   23: invokestatic 371	dm/jdbc/dbaccess/Request_Response:req_more_result	(Ldm/jdbc/dbaccess/DmMsgSend;IS)V
/*      */     //   26: aload_0
/*      */     //   27: invokevirtual 314	dm/jdbc/driver/DmdbStatement_bs:getFromStandby	()Z
/*      */     //   30: ifeq +13 -> 43
/*      */     //   33: aload 4
/*      */     //   35: aload_2
/*      */     //   36: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   39: astore_3
/*      */     //   40: goto +37 -> 77
/*      */     //   43: aload 4
/*      */     //   45: aload_2
/*      */     //   46: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   49: astore_3
/*      */     //   50: goto +27 -> 77
/*      */     //   53: astore 4
/*      */     //   55: sipush 6001
/*      */     //   58: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   61: aload_2
/*      */     //   62: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   65: goto +16 -> 81
/*      */     //   68: astore 5
/*      */     //   70: aload_2
/*      */     //   71: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   74: aload 5
/*      */     //   76: athrow
/*      */     //   77: aload_2
/*      */     //   78: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   81: aload_0
/*      */     //   82: aload_3
/*      */     //   83: invokestatic 320	dm/jdbc/driver/DmdbCSI:getDescAndResultSet	(Ldm/jdbc/driver/DmdbStatement_bs;Ldm/jdbc/dbaccess/DmMsgRecv;)Ldm/jdbc/driver/DmdbInfo;
/*      */     //   86: areturn
/*      */     // Line number table:
/*      */     //   Java source line #716	-> byte code offset #0
/*      */     //   Java source line #718	-> byte code offset #8
/*      */     //   Java source line #720	-> byte code offset #10
/*      */     //   Java source line #721	-> byte code offset #16
/*      */     //   Java source line #722	-> byte code offset #26
/*      */     //   Java source line #724	-> byte code offset #33
/*      */     //   Java source line #725	-> byte code offset #40
/*      */     //   Java source line #728	-> byte code offset #43
/*      */     //   Java source line #730	-> byte code offset #50
/*      */     //   Java source line #731	-> byte code offset #55
/*      */     //   Java source line #733	-> byte code offset #61
/*      */     //   Java source line #732	-> byte code offset #68
/*      */     //   Java source line #733	-> byte code offset #70
/*      */     //   Java source line #734	-> byte code offset #74
/*      */     //   Java source line #733	-> byte code offset #77
/*      */     //   Java source line #736	-> byte code offset #81
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	87	0	stmt	DmdbStatement_bs
/*      */     //   0	87	1	resId	short
/*      */     //   7	71	2	conn	DmdbConnection_bs
/*      */     //   9	74	3	recv	DmMsgRecv
/*      */     //   14	30	4	msg	DmMsgSend
/*      */     //   53	3	4	e	IOException
/*      */     //   68	7	5	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   10	50	53	java/io/IOException
/*      */     //   10	61	68	finally
/*      */   }
/*      */   
/*      */   private static DmdbInfo getDescAndResultSet(DmdbStatement_bs stmt, DmMsgRecv recv)
/*      */     throws SQLException
/*      */   {
/*  753 */     return Request_Response.resp_execute(recv, stmt);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   public static final void putBlobData(DmdbPreparedStatement_bs stmt, int irow, int paramIndex, DmBinder binder)
/*      */     throws SQLException
/*      */   {
/*  773 */     DmMsgSend blobMsg = new DmMsgSend();
/*      */     
/*  775 */     int handle = stmt.getHandle();
/*  776 */     DmdbConnection_bs conn = (DmdbConnection_bs)stmt.getConnection();
/*      */     
/*  778 */     int retLen = 0;
/*      */     for (;;) {
/*  780 */       blobMsg.resetCurNode();
/*  781 */       retLen = binder.bindLobCyc(blobMsg, irow, paramIndex);
/*  782 */       if (retLen == 0) {
/*      */         break;
/*      */       }
/*  785 */       putData(handle, conn, blobMsg, paramIndex, retLen);
/*      */     }
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static final void putData(int handle, DmdbConnection_bs conn, DmMsgSend blobMsg, int paramIndex, int len)
/*      */     throws SQLException
/*      */   {
/*  812 */     DmMsgRecv recvMsg = null;
/*      */     try {
/*  814 */       Request_Response.req_put_data(handle, blobMsg, paramIndex, len);
/*  815 */       recvMsg = access_server(blobMsg, conn);
/*      */     } catch (IOException e) {
/*  817 */       DBError.throwSQLException(6001);
/*      */     }
/*      */     
/*  820 */     Request_Response.resp_put_data(recvMsg, conn);
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final byte[] getBlobData(int stmtHandle, DmdbConnection_bs conn, DmdbLobLocator lobLocator)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: new 408	java/util/Vector
/*      */     //   3: dup
/*      */     //   4: bipush 10
/*      */     //   6: invokespecial 410	java/util/Vector:<init>	(I)V
/*      */     //   9: astore_3
/*      */     //   10: iconst_0
/*      */     //   11: istore 4
/*      */     //   13: aconst_null
/*      */     //   14: astore 5
/*      */     //   16: iconst_0
/*      */     //   17: istore 6
/*      */     //   19: aload_1
/*      */     //   20: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   23: astore 7
/*      */     //   25: goto +50 -> 75
/*      */     //   28: aload 7
/*      */     //   30: iload_0
/*      */     //   31: iload 6
/*      */     //   33: aload_2
/*      */     //   34: invokestatic 412	dm/jdbc/dbaccess/Request_Response:req_get_data	(Ldm/jdbc/dbaccess/DmMsgSend;IILdm/jdbc/driver/DmdbLobLocator;)V
/*      */     //   37: aload 7
/*      */     //   39: aload_1
/*      */     //   40: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   43: astore 5
/*      */     //   45: aload 5
/*      */     //   47: aload_1
/*      */     //   48: aload_2
/*      */     //   49: iload 6
/*      */     //   51: invokestatic 416	dm/jdbc/dbaccess/Request_Response:resp_get_data	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;Ldm/jdbc/driver/DmdbLobLocator;I)Z
/*      */     //   54: istore 4
/*      */     //   56: aload_3
/*      */     //   57: aload_2
/*      */     //   58: getfield 420	dm/jdbc/driver/DmdbLobLocator:m_dataOnceGet	[B
/*      */     //   61: invokevirtual 426	java/util/Vector:add	(Ljava/lang/Object;)Z
/*      */     //   64: pop
/*      */     //   65: iload 6
/*      */     //   67: aload_2
/*      */     //   68: getfield 420	dm/jdbc/driver/DmdbLobLocator:m_dataOnceGet	[B
/*      */     //   71: arraylength
/*      */     //   72: iadd
/*      */     //   73: istore 6
/*      */     //   75: iload 4
/*      */     //   77: ifeq -49 -> 28
/*      */     //   80: goto +27 -> 107
/*      */     //   83: astore 7
/*      */     //   85: sipush 6001
/*      */     //   88: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   91: aload_1
/*      */     //   92: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   95: goto +16 -> 111
/*      */     //   98: astore 8
/*      */     //   100: aload_1
/*      */     //   101: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   104: aload 8
/*      */     //   106: athrow
/*      */     //   107: aload_1
/*      */     //   108: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   111: iload 6
/*      */     //   113: newarray <illegal type>
/*      */     //   115: astore 7
/*      */     //   117: iconst_0
/*      */     //   118: istore 8
/*      */     //   120: aconst_null
/*      */     //   121: astore 9
/*      */     //   123: iconst_0
/*      */     //   124: istore 10
/*      */     //   126: goto +38 -> 164
/*      */     //   129: aload_3
/*      */     //   130: iload 10
/*      */     //   132: invokevirtual 430	java/util/Vector:get	(I)Ljava/lang/Object;
/*      */     //   135: checkcast 434	[B
/*      */     //   138: astore 9
/*      */     //   140: aload 9
/*      */     //   142: iconst_0
/*      */     //   143: aload 7
/*      */     //   145: iload 8
/*      */     //   147: aload 9
/*      */     //   149: arraylength
/*      */     //   150: invokestatic 349	java/lang/System:arraycopy	(Ljava/lang/Object;ILjava/lang/Object;II)V
/*      */     //   153: iload 8
/*      */     //   155: aload 9
/*      */     //   157: arraylength
/*      */     //   158: iadd
/*      */     //   159: istore 8
/*      */     //   161: iinc 10 1
/*      */     //   164: iload 10
/*      */     //   166: aload_3
/*      */     //   167: invokevirtual 435	java/util/Vector:size	()I
/*      */     //   170: if_icmplt -41 -> 129
/*      */     //   173: aload 7
/*      */     //   175: areturn
/*      */     // Line number table:
/*      */     //   Java source line #837	-> byte code offset #0
/*      */     //   Java source line #839	-> byte code offset #10
/*      */     //   Java source line #840	-> byte code offset #13
/*      */     //   Java source line #842	-> byte code offset #16
/*      */     //   Java source line #845	-> byte code offset #19
/*      */     //   Java source line #847	-> byte code offset #25
/*      */     //   Java source line #848	-> byte code offset #28
/*      */     //   Java source line #849	-> byte code offset #33
/*      */     //   Java source line #848	-> byte code offset #34
/*      */     //   Java source line #851	-> byte code offset #37
/*      */     //   Java source line #853	-> byte code offset #45
/*      */     //   Java source line #854	-> byte code offset #48
/*      */     //   Java source line #853	-> byte code offset #51
/*      */     //   Java source line #856	-> byte code offset #56
/*      */     //   Java source line #857	-> byte code offset #65
/*      */     //   Java source line #847	-> byte code offset #75
/*      */     //   Java source line #859	-> byte code offset #80
/*      */     //   Java source line #860	-> byte code offset #85
/*      */     //   Java source line #862	-> byte code offset #91
/*      */     //   Java source line #861	-> byte code offset #98
/*      */     //   Java source line #862	-> byte code offset #100
/*      */     //   Java source line #863	-> byte code offset #104
/*      */     //   Java source line #862	-> byte code offset #107
/*      */     //   Java source line #865	-> byte code offset #111
/*      */     //   Java source line #866	-> byte code offset #117
/*      */     //   Java source line #867	-> byte code offset #120
/*      */     //   Java source line #868	-> byte code offset #123
/*      */     //   Java source line #869	-> byte code offset #129
/*      */     //   Java source line #870	-> byte code offset #140
/*      */     //   Java source line #871	-> byte code offset #153
/*      */     //   Java source line #868	-> byte code offset #161
/*      */     //   Java source line #873	-> byte code offset #173
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	176	0	stmtHandle	int
/*      */     //   0	176	1	conn	DmdbConnection_bs
/*      */     //   0	176	2	lobLocator	DmdbLobLocator
/*      */     //   9	158	3	vec	java.util.Vector
/*      */     //   11	65	4	isOver	boolean
/*      */     //   14	32	5	recvMsg	DmMsgRecv
/*      */     //   17	95	6	cntHasGet	int
/*      */     //   23	15	7	msg	DmMsgSend
/*      */     //   83	3	7	e	IOException
/*      */     //   115	59	7	retData	byte[]
/*      */     //   98	7	8	localObject	Object
/*      */     //   118	42	8	tmp	int
/*      */     //   121	35	9	aBlockData	byte[]
/*      */     //   124	41	10	i	int
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   19	80	83	java/io/IOException
/*      */     //   19	91	98	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final int fetch(DmdbStatement_bs stmt, long curPos, boolean fetchAll, DmdbResultSet_bs resultSet, short resId, boolean fromStandby)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: iconst_0
/*      */     //   1: istore 7
/*      */     //   3: aload_0
/*      */     //   4: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   7: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   10: astore 8
/*      */     //   12: new 451	dm/jdbc/dbaccess/DataOfFetch
/*      */     //   15: dup
/*      */     //   16: ldc2_w 453
/*      */     //   19: lload_1
/*      */     //   20: iload 5
/*      */     //   22: invokespecial 455	dm/jdbc/dbaccess/DataOfFetch:<init>	(JJS)V
/*      */     //   25: astore 9
/*      */     //   27: aconst_null
/*      */     //   28: astore 10
/*      */     //   30: aconst_null
/*      */     //   31: astore 11
/*      */     //   33: aload 8
/*      */     //   35: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   38: astore 12
/*      */     //   40: aload 12
/*      */     //   42: aload_0
/*      */     //   43: invokevirtual 205	dm/jdbc/driver/DmdbStatement_bs:getHandle	()I
/*      */     //   46: aload 9
/*      */     //   48: invokestatic 458	dm/jdbc/dbaccess/Request_Response:req_fetch	(Ldm/jdbc/dbaccess/DmMsgSend;ILdm/jdbc/dbaccess/DataOfFetch;)V
/*      */     //   51: iload 6
/*      */     //   53: ifeq +15 -> 68
/*      */     //   56: aload 12
/*      */     //   58: aload 8
/*      */     //   60: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   63: astore 10
/*      */     //   65: goto +12 -> 77
/*      */     //   68: aload 12
/*      */     //   70: aload 8
/*      */     //   72: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   75: astore 10
/*      */     //   77: aload 10
/*      */     //   79: aload 8
/*      */     //   81: invokestatic 462	dm/jdbc/dbaccess/Request_Response:resp_fetch_checkErr	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)I
/*      */     //   84: istore 7
/*      */     //   86: iload 7
/*      */     //   88: sipush 58500
/*      */     //   91: if_icmpne +21 -> 112
/*      */     //   94: aload 4
/*      */     //   96: ifnull +193 -> 289
/*      */     //   99: aload 4
/*      */     //   101: aload 10
/*      */     //   103: invokevirtual 465	dm/jdbc/dbaccess/DmMsgRecv:res_fetch_get_row_count	()J
/*      */     //   106: putfield 468	dm/jdbc/driver/DmdbResultSet_bs:rowCount	J
/*      */     //   109: goto +180 -> 289
/*      */     //   112: aload 10
/*      */     //   114: aload 9
/*      */     //   116: aload 4
/*      */     //   118: aload 11
/*      */     //   120: iconst_1
/*      */     //   121: invokestatic 473	dm/jdbc/dbaccess/Request_Response:resp_fetch_without_checkErr	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/dbaccess/DataOfFetch;Ldm/jdbc/driver/DmdbResultSet_bs;[BZ)[B
/*      */     //   124: astore 11
/*      */     //   126: aload 4
/*      */     //   128: ifnull +62 -> 190
/*      */     //   131: aload 4
/*      */     //   133: getfield 468	dm/jdbc/driver/DmdbResultSet_bs:rowCount	J
/*      */     //   136: lconst_0
/*      */     //   137: lcmp
/*      */     //   138: ifle +52 -> 190
/*      */     //   141: iload_3
/*      */     //   142: ifeq +30 -> 172
/*      */     //   145: aload 4
/*      */     //   147: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   150: getfield 481	dm/jdbc/driver/DmdbResultSetCache:rownum	I
/*      */     //   153: aload 9
/*      */     //   155: invokevirtual 486	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_get	()I
/*      */     //   158: iadd
/*      */     //   159: i2l
/*      */     //   160: aload 4
/*      */     //   162: getfield 468	dm/jdbc/driver/DmdbResultSet_bs:rowCount	J
/*      */     //   165: lcmp
/*      */     //   166: ifne +24 -> 190
/*      */     //   169: goto +120 -> 289
/*      */     //   172: aload 9
/*      */     //   174: invokevirtual 486	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_get	()I
/*      */     //   177: i2l
/*      */     //   178: aload 4
/*      */     //   180: getfield 468	dm/jdbc/driver/DmdbResultSet_bs:rowCount	J
/*      */     //   183: lcmp
/*      */     //   184: ifne +6 -> 190
/*      */     //   187: goto +102 -> 289
/*      */     //   190: iload 7
/*      */     //   192: bipush 100
/*      */     //   194: if_icmpne +33 -> 227
/*      */     //   197: aload 4
/*      */     //   199: ifnull +90 -> 289
/*      */     //   202: aload 4
/*      */     //   204: getfield 468	dm/jdbc/driver/DmdbResultSet_bs:rowCount	J
/*      */     //   207: ldc2_w 453
/*      */     //   210: lcmp
/*      */     //   211: ifne +78 -> 289
/*      */     //   214: aload 4
/*      */     //   216: aload 9
/*      */     //   218: invokevirtual 489	dm/jdbc/dbaccess/DataOfFetch:getCurPos	()J
/*      */     //   221: putfield 468	dm/jdbc/driver/DmdbResultSet_bs:rowCount	J
/*      */     //   224: goto +65 -> 289
/*      */     //   227: iload_3
/*      */     //   228: ifne +6 -> 234
/*      */     //   231: goto +58 -> 289
/*      */     //   234: aload 11
/*      */     //   236: ifnull -196 -> 40
/*      */     //   239: aload 4
/*      */     //   241: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   244: aload 11
/*      */     //   246: aload 9
/*      */     //   248: invokevirtual 492	dm/jdbc/dbaccess/DataOfFetch:getMsglen_total	()J
/*      */     //   251: l2i
/*      */     //   252: aload 9
/*      */     //   254: invokevirtual 486	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_get	()I
/*      */     //   257: invokevirtual 495	dm/jdbc/driver/DmdbResultSetCache:addBuffer	([BII)V
/*      */     //   260: goto -220 -> 40
/*      */     //   263: astore 12
/*      */     //   265: sipush 6001
/*      */     //   268: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   271: aload 8
/*      */     //   273: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   276: goto +18 -> 294
/*      */     //   279: astore 13
/*      */     //   281: aload 8
/*      */     //   283: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   286: aload 13
/*      */     //   288: athrow
/*      */     //   289: aload 8
/*      */     //   291: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   294: aload 11
/*      */     //   296: ifnull +152 -> 448
/*      */     //   299: iload_3
/*      */     //   300: ifeq +27 -> 327
/*      */     //   303: aload 4
/*      */     //   305: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   308: aload 11
/*      */     //   310: aload 9
/*      */     //   312: invokevirtual 492	dm/jdbc/dbaccess/DataOfFetch:getMsglen_total	()J
/*      */     //   315: l2i
/*      */     //   316: aload 9
/*      */     //   318: invokevirtual 486	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_get	()I
/*      */     //   321: invokevirtual 495	dm/jdbc/driver/DmdbResultSetCache:addBuffer	([BII)V
/*      */     //   324: goto +124 -> 448
/*      */     //   327: aload 4
/*      */     //   329: invokevirtual 499	dm/jdbc/driver/DmdbResultSet_bs:multiRsCaches	()Z
/*      */     //   332: ifeq +95 -> 427
/*      */     //   335: aload_0
/*      */     //   336: invokevirtual 502	dm/jdbc/driver/DmdbStatement_bs:getDmdbInfo	()Ldm/jdbc/driver/DmdbInfo;
/*      */     //   339: invokevirtual 506	dm/jdbc/driver/DmdbInfo:isBdtaRs	()Z
/*      */     //   342: ifeq +32 -> 374
/*      */     //   345: new 509	dm/jdbc/driver/DmdbResultSetCache_v
/*      */     //   348: dup
/*      */     //   349: aload 4
/*      */     //   351: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   354: getfield 511	dm/jdbc/driver/DmdbResultSetCache:statement	Ldm/jdbc/driver/DmdbStatement_bs;
/*      */     //   357: aload 4
/*      */     //   359: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   362: getfield 514	dm/jdbc/driver/DmdbResultSetCache:cols	[Ldm/jdbc/driver/DmdbColumn;
/*      */     //   365: iconst_m1
/*      */     //   366: invokespecial 518	dm/jdbc/driver/DmdbResultSetCache_v:<init>	(Ldm/jdbc/driver/DmdbStatement_bs;[Ldm/jdbc/driver/DmdbColumn;I)V
/*      */     //   369: astore 12
/*      */     //   371: goto +28 -> 399
/*      */     //   374: new 521	dm/jdbc/driver/DmdbResultSetCache_h
/*      */     //   377: dup
/*      */     //   378: aload 4
/*      */     //   380: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   383: getfield 511	dm/jdbc/driver/DmdbResultSetCache:statement	Ldm/jdbc/driver/DmdbStatement_bs;
/*      */     //   386: aload 4
/*      */     //   388: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   391: getfield 514	dm/jdbc/driver/DmdbResultSetCache:cols	[Ldm/jdbc/driver/DmdbColumn;
/*      */     //   394: invokespecial 523	dm/jdbc/driver/DmdbResultSetCache_h:<init>	(Ldm/jdbc/driver/DmdbStatement_bs;[Ldm/jdbc/driver/DmdbColumn;)V
/*      */     //   397: astore 12
/*      */     //   399: aload 12
/*      */     //   401: aload 11
/*      */     //   403: aload 9
/*      */     //   405: invokevirtual 492	dm/jdbc/dbaccess/DataOfFetch:getMsglen_total	()J
/*      */     //   408: l2i
/*      */     //   409: aload 9
/*      */     //   411: invokevirtual 486	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_get	()I
/*      */     //   414: invokevirtual 526	dm/jdbc/driver/DmdbResultSetCache:fillBuffer	([BII)V
/*      */     //   417: aload 4
/*      */     //   419: aload 12
/*      */     //   421: invokevirtual 529	dm/jdbc/driver/DmdbResultSet_bs:addRsCache	(Ldm/jdbc/driver/DmdbResultSetCache;)V
/*      */     //   424: goto +24 -> 448
/*      */     //   427: aload 4
/*      */     //   429: getfield 477	dm/jdbc/driver/DmdbResultSet_bs:rsCache	Ldm/jdbc/driver/DmdbResultSetCache;
/*      */     //   432: aload 11
/*      */     //   434: aload 9
/*      */     //   436: invokevirtual 492	dm/jdbc/dbaccess/DataOfFetch:getMsglen_total	()J
/*      */     //   439: l2i
/*      */     //   440: aload 9
/*      */     //   442: invokevirtual 486	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_get	()I
/*      */     //   445: invokevirtual 526	dm/jdbc/driver/DmdbResultSetCache:fillBuffer	([BII)V
/*      */     //   448: iload 7
/*      */     //   450: ireturn
/*      */     // Line number table:
/*      */     //   Java source line #896	-> byte code offset #0
/*      */     //   Java source line #897	-> byte code offset #3
/*      */     //   Java source line #899	-> byte code offset #12
/*      */     //   Java source line #900	-> byte code offset #20
/*      */     //   Java source line #899	-> byte code offset #22
/*      */     //   Java source line #901	-> byte code offset #27
/*      */     //   Java source line #902	-> byte code offset #30
/*      */     //   Java source line #904	-> byte code offset #33
/*      */     //   Java source line #907	-> byte code offset #40
/*      */     //   Java source line #908	-> byte code offset #51
/*      */     //   Java source line #910	-> byte code offset #56
/*      */     //   Java source line #911	-> byte code offset #65
/*      */     //   Java source line #914	-> byte code offset #68
/*      */     //   Java source line #917	-> byte code offset #77
/*      */     //   Java source line #918	-> byte code offset #86
/*      */     //   Java source line #919	-> byte code offset #94
/*      */     //   Java source line #920	-> byte code offset #99
/*      */     //   Java source line #921	-> byte code offset #109
/*      */     //   Java source line #924	-> byte code offset #112
/*      */     //   Java source line #925	-> byte code offset #114
/*      */     //   Java source line #924	-> byte code offset #121
/*      */     //   Java source line #927	-> byte code offset #126
/*      */     //   Java source line #928	-> byte code offset #141
/*      */     //   Java source line #929	-> byte code offset #145
/*      */     //   Java source line #930	-> byte code offset #153
/*      */     //   Java source line #929	-> byte code offset #158
/*      */     //   Java source line #930	-> byte code offset #160
/*      */     //   Java source line #929	-> byte code offset #165
/*      */     //   Java source line #931	-> byte code offset #169
/*      */     //   Java source line #932	-> byte code offset #172
/*      */     //   Java source line #933	-> byte code offset #187
/*      */     //   Java source line #936	-> byte code offset #190
/*      */     //   Java source line #937	-> byte code offset #197
/*      */     //   Java source line #938	-> byte code offset #202
/*      */     //   Java source line #939	-> byte code offset #214
/*      */     //   Java source line #941	-> byte code offset #224
/*      */     //   Java source line #944	-> byte code offset #227
/*      */     //   Java source line #945	-> byte code offset #231
/*      */     //   Java source line #947	-> byte code offset #234
/*      */     //   Java source line #948	-> byte code offset #239
/*      */     //   Java source line #949	-> byte code offset #246
/*      */     //   Java source line #950	-> byte code offset #252
/*      */     //   Java source line #948	-> byte code offset #257
/*      */     //   Java source line #906	-> byte code offset #260
/*      */     //   Java source line #953	-> byte code offset #263
/*      */     //   Java source line #954	-> byte code offset #265
/*      */     //   Java source line #956	-> byte code offset #271
/*      */     //   Java source line #955	-> byte code offset #279
/*      */     //   Java source line #956	-> byte code offset #281
/*      */     //   Java source line #957	-> byte code offset #286
/*      */     //   Java source line #956	-> byte code offset #289
/*      */     //   Java source line #959	-> byte code offset #294
/*      */     //   Java source line #960	-> byte code offset #299
/*      */     //   Java source line #961	-> byte code offset #303
/*      */     //   Java source line #962	-> byte code offset #310
/*      */     //   Java source line #963	-> byte code offset #316
/*      */     //   Java source line #961	-> byte code offset #321
/*      */     //   Java source line #963	-> byte code offset #324
/*      */     //   Java source line #965	-> byte code offset #327
/*      */     //   Java source line #967	-> byte code offset #335
/*      */     //   Java source line #968	-> byte code offset #345
/*      */     //   Java source line #969	-> byte code offset #349
/*      */     //   Java source line #970	-> byte code offset #357
/*      */     //   Java source line #968	-> byte code offset #366
/*      */     //   Java source line #971	-> byte code offset #371
/*      */     //   Java source line #972	-> byte code offset #374
/*      */     //   Java source line #973	-> byte code offset #378
/*      */     //   Java source line #974	-> byte code offset #386
/*      */     //   Java source line #972	-> byte code offset #394
/*      */     //   Java source line #976	-> byte code offset #399
/*      */     //   Java source line #977	-> byte code offset #409
/*      */     //   Java source line #976	-> byte code offset #414
/*      */     //   Java source line #978	-> byte code offset #417
/*      */     //   Java source line #979	-> byte code offset #424
/*      */     //   Java source line #980	-> byte code offset #427
/*      */     //   Java source line #981	-> byte code offset #434
/*      */     //   Java source line #982	-> byte code offset #440
/*      */     //   Java source line #980	-> byte code offset #445
/*      */     //   Java source line #987	-> byte code offset #448
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	451	0	stmt	DmdbStatement_bs
/*      */     //   0	451	1	curPos	long
/*      */     //   0	451	3	fetchAll	boolean
/*      */     //   0	451	4	resultSet	DmdbResultSet_bs
/*      */     //   0	451	5	resId	short
/*      */     //   0	451	6	fromStandby	boolean
/*      */     //   1	448	7	sqlcode	int
/*      */     //   10	280	8	conn	DmdbConnection_bs
/*      */     //   25	416	9	dataOfFetch	dm.jdbc.dbaccess.DataOfFetch
/*      */     //   28	85	10	recvMsg	DmMsgRecv
/*      */     //   31	402	11	buf	byte[]
/*      */     //   38	31	12	msg	DmMsgSend
/*      */     //   263	3	12	ioex	IOException
/*      */     //   369	3	12	tmp	DmdbResultSetCache
/*      */     //   397	23	12	tmp	DmdbResultSetCache
/*      */     //   279	8	13	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   33	263	263	java/io/IOException
/*      */     //   33	271	279	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   static final void setCursorName(DmdbStatement_bs stmt, String cursorName)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_2
/*      */     //   8: aconst_null
/*      */     //   9: astore_3
/*      */     //   10: aconst_null
/*      */     //   11: astore 4
/*      */     //   13: aload_2
/*      */     //   14: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   17: astore 5
/*      */     //   19: aload 5
/*      */     //   21: aload_2
/*      */     //   22: invokevirtual 236	dm/jdbc/driver/DmdbConnection_bs:getServerEncoding	()Ljava/lang/String;
/*      */     //   25: aload_0
/*      */     //   26: invokevirtual 205	dm/jdbc/driver/DmdbStatement_bs:getHandle	()I
/*      */     //   29: aload_1
/*      */     //   30: invokestatic 542	dm/jdbc/dbaccess/Request_Response:req_cursor_set_name	(Ldm/jdbc/dbaccess/DmMsgSend;Ljava/lang/String;ILjava/lang/String;)V
/*      */     //   33: aload 5
/*      */     //   35: aload_2
/*      */     //   36: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   39: astore_3
/*      */     //   40: aload_3
/*      */     //   41: aload_2
/*      */     //   42: invokestatic 546	dm/jdbc/dbaccess/Request_Response:resp_cursor_set_name	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)V
/*      */     //   45: aload_2
/*      */     //   46: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   49: ifeq +62 -> 111
/*      */     //   52: aload 5
/*      */     //   54: aload_2
/*      */     //   55: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   58: astore 4
/*      */     //   60: aload 4
/*      */     //   62: ifnull +49 -> 111
/*      */     //   65: aload_3
/*      */     //   66: aload_2
/*      */     //   67: invokestatic 546	dm/jdbc/dbaccess/Request_Response:resp_cursor_set_name	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)V
/*      */     //   70: goto +41 -> 111
/*      */     //   73: astore 5
/*      */     //   75: aload_2
/*      */     //   76: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   79: ifeq +10 -> 89
/*      */     //   82: aload_2
/*      */     //   83: invokevirtual 34	dm/jdbc/driver/DmdbConnection_bs:getDbAccess	()Ldm/jdbc/dbaccess/DbAccess;
/*      */     //   86: invokevirtual 173	dm/jdbc/dbaccess/DbAccess:close	()V
/*      */     //   89: sipush 6001
/*      */     //   92: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   95: aload_2
/*      */     //   96: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   99: goto +16 -> 115
/*      */     //   102: astore 6
/*      */     //   104: aload_2
/*      */     //   105: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   108: aload 6
/*      */     //   110: athrow
/*      */     //   111: aload_2
/*      */     //   112: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   115: return
/*      */     // Line number table:
/*      */     //   Java source line #1002	-> byte code offset #0
/*      */     //   Java source line #1003	-> byte code offset #8
/*      */     //   Java source line #1004	-> byte code offset #10
/*      */     //   Java source line #1006	-> byte code offset #13
/*      */     //   Java source line #1007	-> byte code offset #19
/*      */     //   Java source line #1008	-> byte code offset #25
/*      */     //   Java source line #1007	-> byte code offset #30
/*      */     //   Java source line #1010	-> byte code offset #33
/*      */     //   Java source line #1011	-> byte code offset #40
/*      */     //   Java source line #1013	-> byte code offset #45
/*      */     //   Java source line #1014	-> byte code offset #52
/*      */     //   Java source line #1015	-> byte code offset #60
/*      */     //   Java source line #1016	-> byte code offset #65
/*      */     //   Java source line #1018	-> byte code offset #70
/*      */     //   Java source line #1019	-> byte code offset #75
/*      */     //   Java source line #1020	-> byte code offset #82
/*      */     //   Java source line #1022	-> byte code offset #89
/*      */     //   Java source line #1024	-> byte code offset #95
/*      */     //   Java source line #1023	-> byte code offset #102
/*      */     //   Java source line #1024	-> byte code offset #104
/*      */     //   Java source line #1025	-> byte code offset #108
/*      */     //   Java source line #1024	-> byte code offset #111
/*      */     //   Java source line #1026	-> byte code offset #115
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	116	0	stmt	DmdbStatement_bs
/*      */     //   0	116	1	cursorName	String
/*      */     //   7	105	2	conn	DmdbConnection_bs
/*      */     //   9	57	3	recvMsg	DmMsgRecv
/*      */     //   11	50	4	recvMsgS	DmMsgRecv
/*      */     //   17	36	5	msg	DmMsgSend
/*      */     //   73	3	5	ioex	IOException
/*      */     //   102	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   13	70	73	java/io/IOException
/*      */     //   13	95	102	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final String getExplainInfo(DmdbStatement_bs stmt, String sqlToExplain)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_1
/*      */     //   1: ifnull +13 -> 14
/*      */     //   4: aload_1
/*      */     //   5: invokevirtual 552	java/lang/String:trim	()Ljava/lang/String;
/*      */     //   8: invokevirtual 109	java/lang/String:length	()I
/*      */     //   11: ifne +9 -> 20
/*      */     //   14: sipush 6003
/*      */     //   17: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   20: aload_1
/*      */     //   21: ldc_w 555
/*      */     //   24: invokevirtual 557	java/lang/String:equalsIgnoreCase	(Ljava/lang/String;)Z
/*      */     //   27: ifne +21 -> 48
/*      */     //   30: new 561	java/lang/StringBuffer
/*      */     //   33: dup
/*      */     //   34: ldc_w 563
/*      */     //   37: invokespecial 565	java/lang/StringBuffer:<init>	(Ljava/lang/String;)V
/*      */     //   40: aload_1
/*      */     //   41: invokevirtual 567	java/lang/StringBuffer:append	(Ljava/lang/String;)Ljava/lang/StringBuffer;
/*      */     //   44: invokevirtual 571	java/lang/StringBuffer:toString	()Ljava/lang/String;
/*      */     //   47: astore_1
/*      */     //   48: aload_0
/*      */     //   49: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   52: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   55: astore_2
/*      */     //   56: aload_2
/*      */     //   57: invokevirtual 236	dm/jdbc/driver/DmdbConnection_bs:getServerEncoding	()Ljava/lang/String;
/*      */     //   60: astore_3
/*      */     //   61: aconst_null
/*      */     //   62: astore 4
/*      */     //   64: aload_2
/*      */     //   65: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   68: astore 5
/*      */     //   70: aload 5
/*      */     //   72: aload_0
/*      */     //   73: aload_1
/*      */     //   74: iconst_1
/*      */     //   75: iconst_0
/*      */     //   76: invokestatic 224	dm/jdbc/dbaccess/Request_Response:req_prepare	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbStatement_bs;Ljava/lang/String;ZI)V
/*      */     //   79: aload 5
/*      */     //   81: aload_2
/*      */     //   82: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   85: astore 4
/*      */     //   87: goto +27 -> 114
/*      */     //   90: astore 5
/*      */     //   92: sipush 6001
/*      */     //   95: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   98: aload_2
/*      */     //   99: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   102: goto +16 -> 118
/*      */     //   105: astore 6
/*      */     //   107: aload_2
/*      */     //   108: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   111: aload 6
/*      */     //   113: athrow
/*      */     //   114: aload_2
/*      */     //   115: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   118: aload 4
/*      */     //   120: aload_3
/*      */     //   121: aload_0
/*      */     //   122: iconst_1
/*      */     //   123: invokestatic 239	dm/jdbc/dbaccess/Request_Response:resp_prepare	(Ldm/jdbc/dbaccess/DmMsgRecv;Ljava/lang/String;Ldm/jdbc/driver/DmdbStatement_bs;Z)Ldm/jdbc/driver/DmdbInfo;
/*      */     //   126: astore 5
/*      */     //   128: aload 5
/*      */     //   130: invokevirtual 574	dm/jdbc/driver/DmdbInfo:getExplain	()Ljava/lang/String;
/*      */     //   133: areturn
/*      */     // Line number table:
/*      */     //   Java source line #1043	-> byte code offset #0
/*      */     //   Java source line #1044	-> byte code offset #14
/*      */     //   Java source line #1046	-> byte code offset #20
/*      */     //   Java source line #1047	-> byte code offset #30
/*      */     //   Java source line #1049	-> byte code offset #48
/*      */     //   Java source line #1050	-> byte code offset #56
/*      */     //   Java source line #1051	-> byte code offset #61
/*      */     //   Java source line #1053	-> byte code offset #64
/*      */     //   Java source line #1054	-> byte code offset #70
/*      */     //   Java source line #1055	-> byte code offset #79
/*      */     //   Java source line #1056	-> byte code offset #87
/*      */     //   Java source line #1057	-> byte code offset #92
/*      */     //   Java source line #1059	-> byte code offset #98
/*      */     //   Java source line #1058	-> byte code offset #105
/*      */     //   Java source line #1059	-> byte code offset #107
/*      */     //   Java source line #1060	-> byte code offset #111
/*      */     //   Java source line #1059	-> byte code offset #114
/*      */     //   Java source line #1062	-> byte code offset #118
/*      */     //   Java source line #1063	-> byte code offset #121
/*      */     //   Java source line #1062	-> byte code offset #123
/*      */     //   Java source line #1065	-> byte code offset #128
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	134	0	stmt	DmdbStatement_bs
/*      */     //   0	134	1	sqlToExplain	String
/*      */     //   55	60	2	conn	DmdbConnection_bs
/*      */     //   60	61	3	serverEncoding	String
/*      */     //   62	57	4	recvMsg	DmMsgRecv
/*      */     //   68	12	5	msg	DmMsgSend
/*      */     //   90	3	5	ioex	IOException
/*      */     //   126	3	5	des	DmdbInfo
/*      */     //   105	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   64	87	90	java/io/IOException
/*      */     //   64	98	105	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final long blob_text_truncate(DmdbLob lob, byte flag, int length)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   4: astore_3
/*      */     //   5: aconst_null
/*      */     //   6: astore 4
/*      */     //   8: aload_3
/*      */     //   9: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   12: astore 5
/*      */     //   14: aload 5
/*      */     //   16: aload_0
/*      */     //   17: invokevirtual 586	dm/jdbc/driver/DmdbLob:getLobLocator	()Ldm/jdbc/driver/DmdbLobLocator;
/*      */     //   20: iload_2
/*      */     //   21: invokestatic 590	dm/jdbc/dbaccess/Request_Response:req_lob_truncate	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbLobLocator;I)V
/*      */     //   24: aload 5
/*      */     //   26: aload_3
/*      */     //   27: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   30: astore 4
/*      */     //   32: goto +27 -> 59
/*      */     //   35: astore 5
/*      */     //   37: sipush 6001
/*      */     //   40: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   43: aload_3
/*      */     //   44: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   47: goto +16 -> 63
/*      */     //   50: astore 6
/*      */     //   52: aload_3
/*      */     //   53: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   56: aload 6
/*      */     //   58: athrow
/*      */     //   59: aload_3
/*      */     //   60: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   63: aload 4
/*      */     //   65: aload_0
/*      */     //   66: invokevirtual 586	dm/jdbc/driver/DmdbLob:getLobLocator	()Ldm/jdbc/driver/DmdbLobLocator;
/*      */     //   69: aload_0
/*      */     //   70: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   73: invokestatic 594	dm/jdbc/dbaccess/Request_Response:resp_lob_truncate	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbLobLocator;Ldm/jdbc/driver/DmdbConnection_bs;)J
/*      */     //   76: lreturn
/*      */     // Line number table:
/*      */     //   Java source line #1084	-> byte code offset #0
/*      */     //   Java source line #1086	-> byte code offset #5
/*      */     //   Java source line #1088	-> byte code offset #8
/*      */     //   Java source line #1089	-> byte code offset #14
/*      */     //   Java source line #1090	-> byte code offset #24
/*      */     //   Java source line #1091	-> byte code offset #32
/*      */     //   Java source line #1092	-> byte code offset #37
/*      */     //   Java source line #1094	-> byte code offset #43
/*      */     //   Java source line #1093	-> byte code offset #50
/*      */     //   Java source line #1094	-> byte code offset #52
/*      */     //   Java source line #1095	-> byte code offset #56
/*      */     //   Java source line #1094	-> byte code offset #59
/*      */     //   Java source line #1097	-> byte code offset #63
/*      */     //   Java source line #1098	-> byte code offset #69
/*      */     //   Java source line #1097	-> byte code offset #73
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	77	0	lob	DmdbLob
/*      */     //   0	77	1	flag	byte
/*      */     //   0	77	2	length	int
/*      */     //   4	56	3	conn	DmdbConnection_bs
/*      */     //   6	58	4	recv	DmMsgRecv
/*      */     //   12	13	5	msg	DmMsgSend
/*      */     //   35	3	5	ioex	IOException
/*      */     //   50	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   8	32	35	java/io/IOException
/*      */     //   8	43	50	finally
/*      */   }
/*      */   
/*      */   public static final long lob_get_len(DmdbLob lob)
/*      */     throws SQLException
/*      */   {
/* 1112 */     DmMsgSend lobMsg = new DmMsgSend();
/* 1113 */     DmMsgRecv recv = null;
/*      */     try {
/* 1115 */       Request_Response.req_get_lob_len(lobMsg, lob.getLobLocator());
/* 1116 */       recv = access_server(lobMsg, lob.getConnection());
/*      */     } catch (IOException ioex) {
/* 1118 */       DBError.throwSQLException(6001);
/*      */     }
/*      */     
/* 1121 */     return Request_Response.resp_get_lob_len(recv, lob);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   public static final byte[] lob_get_bytes(DmdbLob lob, byte flag, int start_pos, int length)
/*      */     throws SQLException
/*      */   {
/* 1140 */     DmMsgSend blobMsg = new DmMsgSend();
/* 1141 */     DmMsgRecv recv = null;
/*      */     try {
/* 1143 */       Request_Response.req_get_lob_data(blobMsg, lob.getLobLocator(), 
/* 1144 */         start_pos, length);
/* 1145 */       recv = access_server(blobMsg, lob.getConnection());
/*      */     } catch (IOException ioex) {
/* 1147 */       DBError.throwSQLException(6001);
/*      */     }
/*      */     
/* 1150 */     return Request_Response.resp_get_lob_data(recv, lob.getLobLocator(), 
/* 1151 */       lob.getConnection());
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final int lob_set_bytes(DmdbLob lob, byte flag, int start_pos, byte[] buf, int off, int len, byte firstOrLast)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore 7
/*      */     //   3: aload_0
/*      */     //   4: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   7: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   10: astore 8
/*      */     //   12: aload 8
/*      */     //   14: aload_0
/*      */     //   15: invokevirtual 586	dm/jdbc/driver/DmdbLob:getLobLocator	()Ldm/jdbc/driver/DmdbLobLocator;
/*      */     //   18: iload_2
/*      */     //   19: aload_3
/*      */     //   20: iload 4
/*      */     //   22: iload 5
/*      */     //   24: iload 6
/*      */     //   26: invokestatic 626	dm/jdbc/dbaccess/Request_Response:req_set_lob_data	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbLobLocator;I[BIIB)V
/*      */     //   29: aload 8
/*      */     //   31: aload_0
/*      */     //   32: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   35: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   38: astore 7
/*      */     //   40: goto +33 -> 73
/*      */     //   43: astore 8
/*      */     //   45: sipush 6001
/*      */     //   48: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   51: aload_0
/*      */     //   52: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   55: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   58: goto +22 -> 80
/*      */     //   61: astore 9
/*      */     //   63: aload_0
/*      */     //   64: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   67: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   70: aload 9
/*      */     //   72: athrow
/*      */     //   73: aload_0
/*      */     //   74: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   77: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   80: aload 7
/*      */     //   82: aload_0
/*      */     //   83: invokevirtual 586	dm/jdbc/driver/DmdbLob:getLobLocator	()Ldm/jdbc/driver/DmdbLobLocator;
/*      */     //   86: aload_0
/*      */     //   87: invokevirtual 582	dm/jdbc/driver/DmdbLob:getConnection	()Ldm/jdbc/driver/DmdbConnection_bs;
/*      */     //   90: invokestatic 630	dm/jdbc/dbaccess/Request_Response:resp_set_lob_data	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbLobLocator;Ldm/jdbc/driver/DmdbConnection_bs;)I
/*      */     //   93: ireturn
/*      */     // Line number table:
/*      */     //   Java source line #1177	-> byte code offset #0
/*      */     //   Java source line #1179	-> byte code offset #3
/*      */     //   Java source line #1180	-> byte code offset #12
/*      */     //   Java source line #1181	-> byte code offset #18
/*      */     //   Java source line #1180	-> byte code offset #26
/*      */     //   Java source line #1182	-> byte code offset #29
/*      */     //   Java source line #1183	-> byte code offset #40
/*      */     //   Java source line #1184	-> byte code offset #45
/*      */     //   Java source line #1186	-> byte code offset #51
/*      */     //   Java source line #1185	-> byte code offset #61
/*      */     //   Java source line #1186	-> byte code offset #63
/*      */     //   Java source line #1187	-> byte code offset #70
/*      */     //   Java source line #1186	-> byte code offset #73
/*      */     //   Java source line #1189	-> byte code offset #80
/*      */     //   Java source line #1190	-> byte code offset #86
/*      */     //   Java source line #1189	-> byte code offset #90
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	94	0	lob	DmdbLob
/*      */     //   0	94	1	flag	byte
/*      */     //   0	94	2	start_pos	int
/*      */     //   0	94	3	buf	byte[]
/*      */     //   0	94	4	off	int
/*      */     //   0	94	5	len	int
/*      */     //   0	94	6	firstOrLast	byte
/*      */     //   1	80	7	recv	DmMsgRecv
/*      */     //   10	20	8	msg	DmMsgSend
/*      */     //   43	3	8	ioex	IOException
/*      */     //   61	10	9	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   3	40	43	java/io/IOException
/*      */     //   3	51	61	finally
/*      */   }
/*      */   
/*      */   public static final String text_get_subString(DmdbLob lob, byte flag, int pos, int len)
/*      */     throws SQLException
/*      */   {
/* 1210 */     String str = null;
/* 1211 */     byte[] bs = lob_get_bytes(lob, flag, pos, len);
/*      */     try {
/* 1213 */       String serverEncoding = lob.getConnection().getServerEncoding();
/* 1214 */       if (bs != null)
/* 1215 */         str = new String(bs, serverEncoding);
/*      */     } catch (Exception e) {
/* 1217 */       throw new SQLException(e.getMessage());
/*      */     }
/* 1219 */     return str;
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static int[] getBatchRowCounts(DmMsgRecv recv, DmdbStatement_bs stmt)
/*      */     throws SQLException
/*      */   {
/* 1234 */     return Request_Response.resp_execute_for_batch(recv, stmt);
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final long getRowCount(DmdbStatement_bs stmt, boolean fromStandby)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aload_0
/*      */     //   1: invokevirtual 186	dm/jdbc/driver/DmdbStatement_bs:getConnection	()Ljava/sql/Connection;
/*      */     //   4: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   7: astore_2
/*      */     //   8: new 451	dm/jdbc/dbaccess/DataOfFetch
/*      */     //   11: dup
/*      */     //   12: lconst_1
/*      */     //   13: ldc2_w 453
/*      */     //   16: iconst_0
/*      */     //   17: invokespecial 455	dm/jdbc/dbaccess/DataOfFetch:<init>	(JJS)V
/*      */     //   20: astore_3
/*      */     //   21: aconst_null
/*      */     //   22: astore 4
/*      */     //   24: aload_2
/*      */     //   25: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   28: astore 5
/*      */     //   30: aload 5
/*      */     //   32: aload_0
/*      */     //   33: getfield 657	dm/jdbc/driver/DmdbStatement_bs:handle	I
/*      */     //   36: aload_3
/*      */     //   37: invokestatic 458	dm/jdbc/dbaccess/Request_Response:req_fetch	(Ldm/jdbc/dbaccess/DmMsgSend;ILdm/jdbc/dbaccess/DataOfFetch;)V
/*      */     //   40: iload_1
/*      */     //   41: ifeq +14 -> 55
/*      */     //   44: aload 5
/*      */     //   46: aload_2
/*      */     //   47: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   50: astore 4
/*      */     //   52: goto +38 -> 90
/*      */     //   55: aload 5
/*      */     //   57: aload_2
/*      */     //   58: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   61: astore 4
/*      */     //   63: goto +27 -> 90
/*      */     //   66: astore 5
/*      */     //   68: sipush 6001
/*      */     //   71: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   74: aload_2
/*      */     //   75: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   78: goto +16 -> 94
/*      */     //   81: astore 6
/*      */     //   83: aload_2
/*      */     //   84: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   87: aload 6
/*      */     //   89: athrow
/*      */     //   90: aload_2
/*      */     //   91: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   94: aload 4
/*      */     //   96: aload_2
/*      */     //   97: invokestatic 462	dm/jdbc/dbaccess/Request_Response:resp_fetch_checkErr	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)I
/*      */     //   100: pop
/*      */     //   101: aload 4
/*      */     //   103: aload_3
/*      */     //   104: aconst_null
/*      */     //   105: aconst_null
/*      */     //   106: iconst_0
/*      */     //   107: invokestatic 473	dm/jdbc/dbaccess/Request_Response:resp_fetch_without_checkErr	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/dbaccess/DataOfFetch;Ldm/jdbc/driver/DmdbResultSet_bs;[BZ)[B
/*      */     //   110: pop
/*      */     //   111: aload_3
/*      */     //   112: invokevirtual 659	dm/jdbc/dbaccess/DataOfFetch:getResRowCnt_total	()J
/*      */     //   115: lreturn
/*      */     // Line number table:
/*      */     //   Java source line #1248	-> byte code offset #0
/*      */     //   Java source line #1249	-> byte code offset #8
/*      */     //   Java source line #1251	-> byte code offset #21
/*      */     //   Java source line #1253	-> byte code offset #24
/*      */     //   Java source line #1254	-> byte code offset #30
/*      */     //   Java source line #1255	-> byte code offset #40
/*      */     //   Java source line #1257	-> byte code offset #44
/*      */     //   Java source line #1258	-> byte code offset #52
/*      */     //   Java source line #1261	-> byte code offset #55
/*      */     //   Java source line #1263	-> byte code offset #63
/*      */     //   Java source line #1264	-> byte code offset #68
/*      */     //   Java source line #1266	-> byte code offset #74
/*      */     //   Java source line #1265	-> byte code offset #81
/*      */     //   Java source line #1266	-> byte code offset #83
/*      */     //   Java source line #1267	-> byte code offset #87
/*      */     //   Java source line #1266	-> byte code offset #90
/*      */     //   Java source line #1269	-> byte code offset #94
/*      */     //   Java source line #1270	-> byte code offset #101
/*      */     //   Java source line #1271	-> byte code offset #105
/*      */     //   Java source line #1270	-> byte code offset #107
/*      */     //   Java source line #1273	-> byte code offset #111
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	116	0	stmt	DmdbStatement_bs
/*      */     //   0	116	1	fromStandby	boolean
/*      */     //   7	90	2	conn	DmdbConnection_bs
/*      */     //   20	92	3	dataFetch	dm.jdbc.dbaccess.DataOfFetch
/*      */     //   22	80	4	recvMsg	DmMsgRecv
/*      */     //   28	28	5	msg	DmMsgSend
/*      */     //   66	3	5	ioex	IOException
/*      */     //   81	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   24	63	66	java/io/IOException
/*      */     //   24	74	81	finally
/*      */   }
/*      */   
/*      */   public static final void preExec(DmdbStatement_bs stmt, ParameterDesc[] paramsDesc)
/*      */     throws SQLException
/*      */   {
/* 1291 */     DmMsgSend blobMsg = new DmMsgSend();
/* 1292 */     DmMsgRecv recvMsg = null;
/* 1293 */     DmdbConnection_bs conn = (DmdbConnection_bs)stmt.getConnection();
/*      */     try
/*      */     {
/* 1296 */       Request_Response.req_pre_exec(stmt.getHandle(), blobMsg, paramsDesc);
/* 1297 */       recvMsg = access_server(blobMsg, conn);
/*      */     } catch (IOException ioex) {
/* 1299 */       DBError.throwSQLException(6001);
/*      */     }
/*      */     
/* 1302 */     Request_Response.resp_pre_exec(recvMsg, conn);
/*      */   }
/*      */   
/*      */ 
/*      */   public static final void preExec(DmdbStatement_bs stmt, DmBinder[] binders, boolean forBatch)
/*      */     throws SQLException
/*      */   {
/* 1309 */     DmMsgSend blobMsg = new DmMsgSend();
/* 1310 */     DmMsgRecv recvMsg = null;
/* 1311 */     DmdbConnection_bs conn = (DmdbConnection_bs)stmt.getConnection();
/*      */     try {
/* 1313 */       Request_Response.req_pre_exec(stmt.getHandle(), blobMsg, binders, 
/* 1314 */         forBatch);
/* 1315 */       recvMsg = access_server(blobMsg, conn);
/*      */     } catch (IOException ioex) {
/* 1317 */       DBError.throwSQLException(6001);
/*      */     }
/*      */     
/* 1320 */     Request_Response.resp_pre_exec(recvMsg, conn);
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   static final void setSessionIsoLevel(int isoLevel, DmdbConnection_bs conn)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore_2
/*      */     //   2: aload_1
/*      */     //   3: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   6: astore_3
/*      */     //   7: aload_3
/*      */     //   8: iload_0
/*      */     //   9: invokestatic 683	dm/jdbc/dbaccess/Request_Response:req_sess_iso	(Ldm/jdbc/dbaccess/DmMsgSend;I)V
/*      */     //   12: aload_3
/*      */     //   13: aload_1
/*      */     //   14: invokestatic 143	dm/jdbc/driver/DmdbCSI:accessToPrimary	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   17: astore_2
/*      */     //   18: aload_2
/*      */     //   19: aload_1
/*      */     //   20: invokestatic 686	dm/jdbc/dbaccess/Request_Response:resp_sess_iso	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)V
/*      */     //   23: aload_1
/*      */     //   24: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   27: ifeq +49 -> 76
/*      */     //   30: aload_3
/*      */     //   31: aload_1
/*      */     //   32: invokestatic 153	dm/jdbc/driver/DmdbCSI:accessToStandby	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   35: pop
/*      */     //   36: goto +40 -> 76
/*      */     //   39: astore_3
/*      */     //   40: aload_1
/*      */     //   41: invokevirtual 150	dm/jdbc/driver/DmdbConnection_bs:checkHasStandby	()Z
/*      */     //   44: ifeq +10 -> 54
/*      */     //   47: aload_1
/*      */     //   48: invokevirtual 34	dm/jdbc/driver/DmdbConnection_bs:getDbAccess	()Ldm/jdbc/dbaccess/DbAccess;
/*      */     //   51: invokevirtual 173	dm/jdbc/dbaccess/DbAccess:close	()V
/*      */     //   54: sipush 6001
/*      */     //   57: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   60: aload_1
/*      */     //   61: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   64: goto +16 -> 80
/*      */     //   67: astore 4
/*      */     //   69: aload_1
/*      */     //   70: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   73: aload 4
/*      */     //   75: athrow
/*      */     //   76: aload_1
/*      */     //   77: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   80: return
/*      */     // Line number table:
/*      */     //   Java source line #1334	-> byte code offset #0
/*      */     //   Java source line #1336	-> byte code offset #2
/*      */     //   Java source line #1337	-> byte code offset #7
/*      */     //   Java source line #1338	-> byte code offset #12
/*      */     //   Java source line #1339	-> byte code offset #18
/*      */     //   Java source line #1340	-> byte code offset #23
/*      */     //   Java source line #1341	-> byte code offset #30
/*      */     //   Java source line #1343	-> byte code offset #36
/*      */     //   Java source line #1344	-> byte code offset #40
/*      */     //   Java source line #1345	-> byte code offset #47
/*      */     //   Java source line #1347	-> byte code offset #54
/*      */     //   Java source line #1349	-> byte code offset #60
/*      */     //   Java source line #1348	-> byte code offset #67
/*      */     //   Java source line #1349	-> byte code offset #69
/*      */     //   Java source line #1350	-> byte code offset #73
/*      */     //   Java source line #1349	-> byte code offset #76
/*      */     //   Java source line #1351	-> byte code offset #80
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	81	0	isoLevel	int
/*      */     //   0	81	1	conn	DmdbConnection_bs
/*      */     //   1	18	2	recv	DmMsgRecv
/*      */     //   6	25	3	msg	DmMsgSend
/*      */     //   39	2	3	ioex	IOException
/*      */     //   67	7	4	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   2	36	39	java/io/IOException
/*      */     //   2	60	67	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final long[] table_ts(DmdbConnection_bs conn, long[] tbIds)
/*      */     throws SQLException
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore_2
/*      */     //   2: aload_0
/*      */     //   3: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   6: astore_3
/*      */     //   7: aload_3
/*      */     //   8: aload_1
/*      */     //   9: invokestatic 692	dm/jdbc/dbaccess/Request_Response:req_table_ts	(Ldm/jdbc/dbaccess/DmMsgSend;[J)V
/*      */     //   12: aload_3
/*      */     //   13: aload_0
/*      */     //   14: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   17: astore_2
/*      */     //   18: goto +26 -> 44
/*      */     //   21: astore_3
/*      */     //   22: sipush 6001
/*      */     //   25: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   28: aload_0
/*      */     //   29: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   32: goto +16 -> 48
/*      */     //   35: astore 4
/*      */     //   37: aload_0
/*      */     //   38: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   41: aload 4
/*      */     //   43: athrow
/*      */     //   44: aload_0
/*      */     //   45: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   48: aload_2
/*      */     //   49: aload_0
/*      */     //   50: invokestatic 696	dm/jdbc/dbaccess/Request_Response:resp_table_ts	(Ldm/jdbc/dbaccess/DmMsgRecv;Ldm/jdbc/driver/DmdbConnection_bs;)[J
/*      */     //   53: areturn
/*      */     // Line number table:
/*      */     //   Java source line #1355	-> byte code offset #0
/*      */     //   Java source line #1357	-> byte code offset #2
/*      */     //   Java source line #1358	-> byte code offset #7
/*      */     //   Java source line #1359	-> byte code offset #12
/*      */     //   Java source line #1360	-> byte code offset #18
/*      */     //   Java source line #1361	-> byte code offset #22
/*      */     //   Java source line #1363	-> byte code offset #28
/*      */     //   Java source line #1362	-> byte code offset #35
/*      */     //   Java source line #1363	-> byte code offset #37
/*      */     //   Java source line #1364	-> byte code offset #41
/*      */     //   Java source line #1363	-> byte code offset #44
/*      */     //   Java source line #1366	-> byte code offset #48
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	54	0	conn	DmdbConnection_bs
/*      */     //   0	54	1	tbIds	long[]
/*      */     //   1	48	2	recv	DmMsgRecv
/*      */     //   6	7	3	msg	DmMsgSend
/*      */     //   21	2	3	ioex	IOException
/*      */     //   35	7	4	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   2	18	21	java/io/IOException
/*      */     //   2	28	35	finally
/*      */   }
/*      */   
/*      */   private static final boolean access_with_switch_need(DmdbConnection_bs conn, DmMsgRecv recvMsg)
/*      */   {
/* 1380 */     int retType = Request_Response.resp_ret_type(recvMsg);
/* 1381 */     int svrMode = Request_Response.resp_svr_mode(recvMsg);
/*      */     
/* 1383 */     if ((228 == retType) || (163 == retType)) {
/* 1384 */       return false;
/*      */     }
/* 1386 */     if ((2 == svrMode) && 
/* 1387 */       (1 == conn.getSvrMode())) {
/* 1388 */       return true;
/*      */     }
/* 1390 */     return false;
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static final DmMsgRecv access_with_switch(DmMsgSend sendMsg, DmdbConnection_bs conn)
/*      */     throws SQLException
/*      */   {
/* 1406 */     DmMsgRecv retMsg = null;
/*      */     try
/*      */     {
/*      */       try {
/* 1410 */         retMsg = access_without_switch(sendMsg, conn);
/*      */       } catch (IOException e) {
/* 1412 */         conn.getDbSwitch().doSwitch();
/* 1413 */         DBError.throwSQLException(20000);
/*      */       }
/*      */       
/* 1416 */       if (access_with_switch_need(conn, retMsg)) {
/* 1417 */         conn.getDbSwitch().doSwitch();
/* 1418 */         DBError.throwSQLException(20000);
/*      */       }
/*      */     }
/*      */     catch (IOException ex) {
/* 1422 */       DBError.throwSQLException(20001);
/*      */     }
/*      */     
/* 1425 */     return retMsg;
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static final DmMsgRecv access_without_switch(DmMsgSend sendMsg, DmdbConnection_bs conn)
/*      */     throws SQLException, IOException
/*      */   {
/* 1441 */     return conn.getDbAccess().access(sendMsg);
/*      */   }
/*      */   
/*      */   private static final DmMsgRecv accessToStandby(DmMsgSend sendMsg, DmdbConnection_bs conn) throws SQLException, IOException
/*      */   {
/* 1446 */     return conn.getDbAccess().accessStandby(sendMsg);
/*      */   }
/*      */   
/*      */   private static final DmMsgRecv accessToPrimary(DmMsgSend sendMsg, DmdbConnection_bs conn) throws SQLException, IOException
/*      */   {
/* 1451 */     return conn.getDbAccess().accessPrimary(sendMsg);
/*      */   }
/*      */   
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */ 
/*      */   private static final DmMsgRecv access_server(DmMsgSend sendMsg, DmdbConnection_bs conn)
/*      */     throws SQLException, IOException
/*      */   {
/* 1467 */     if ((!conn.hasOneSvr()) && (conn.doSwitch())) {
/* 1468 */       return access_with_switch(sendMsg, conn);
/*      */     }
/*      */     
/* 1471 */     return access_without_switch(sendMsg, conn);
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final synchronized int xa_process(DmdbConnection_bs conn, int xa_type, javax.transaction.xa.Xid xid, int flag)
/*      */     throws Exception
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore 4
/*      */     //   3: aload_0
/*      */     //   4: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   7: astore 5
/*      */     //   9: aload 5
/*      */     //   11: iload_1
/*      */     //   12: aload_2
/*      */     //   13: iload_3
/*      */     //   14: invokestatic 739	dm/jdbc/dbaccess/Request_Response:req_xa_common	(Ldm/jdbc/dbaccess/DmMsgSend;ILjavax/transaction/xa/Xid;I)V
/*      */     //   17: aload 5
/*      */     //   19: aload_0
/*      */     //   20: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   23: astore 4
/*      */     //   25: goto +27 -> 52
/*      */     //   28: astore 5
/*      */     //   30: sipush 6001
/*      */     //   33: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   36: aload_0
/*      */     //   37: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   40: goto +16 -> 56
/*      */     //   43: astore 6
/*      */     //   45: aload_0
/*      */     //   46: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   49: aload 6
/*      */     //   51: athrow
/*      */     //   52: aload_0
/*      */     //   53: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   56: aload 4
/*      */     //   58: invokestatic 743	dm/jdbc/dbaccess/Request_Response:resp_xa_common	(Ldm/jdbc/dbaccess/DmMsgRecv;)I
/*      */     //   61: ireturn
/*      */     // Line number table:
/*      */     //   Java source line #1477	-> byte code offset #0
/*      */     //   Java source line #1480	-> byte code offset #3
/*      */     //   Java source line #1481	-> byte code offset #9
/*      */     //   Java source line #1482	-> byte code offset #17
/*      */     //   Java source line #1483	-> byte code offset #25
/*      */     //   Java source line #1484	-> byte code offset #30
/*      */     //   Java source line #1486	-> byte code offset #36
/*      */     //   Java source line #1485	-> byte code offset #43
/*      */     //   Java source line #1486	-> byte code offset #45
/*      */     //   Java source line #1487	-> byte code offset #49
/*      */     //   Java source line #1486	-> byte code offset #52
/*      */     //   Java source line #1489	-> byte code offset #56
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	62	0	conn	DmdbConnection_bs
/*      */     //   0	62	1	xa_type	int
/*      */     //   0	62	2	xid	javax.transaction.xa.Xid
/*      */     //   0	62	3	flag	int
/*      */     //   1	56	4	recvMsg	DmMsgRecv
/*      */     //   7	11	5	msg	DmMsgSend
/*      */     //   28	3	5	e	IOException
/*      */     //   43	7	6	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   3	25	28	java/io/IOException
/*      */     //   3	36	43	finally
/*      */   }
/*      */   
/*      */   /* Error */
/*      */   public static final synchronized dm.jdbc.xa.DmdbXid[] xa_recover(dm.jdbc.xa.DmdbXAResource xaResource, int flag)
/*      */     throws Exception
/*      */   {
/*      */     // Byte code:
/*      */     //   0: aconst_null
/*      */     //   1: astore_2
/*      */     //   2: aload_0
/*      */     //   3: invokevirtual 752	dm/jdbc/xa/DmdbXAResource:getConnection	()Ljava/sql/Connection;
/*      */     //   6: checkcast 35	dm/jdbc/driver/DmdbConnection_bs
/*      */     //   9: astore_3
/*      */     //   10: aload_3
/*      */     //   11: invokevirtual 135	dm/jdbc/driver/DmdbConnection_bs:getMsg	()Ldm/jdbc/dbaccess/DmMsgSend;
/*      */     //   14: astore 4
/*      */     //   16: aload 4
/*      */     //   18: iconst_5
/*      */     //   19: aconst_null
/*      */     //   20: iload_1
/*      */     //   21: invokestatic 739	dm/jdbc/dbaccess/Request_Response:req_xa_common	(Ldm/jdbc/dbaccess/DmMsgSend;ILjavax/transaction/xa/Xid;I)V
/*      */     //   24: aload 4
/*      */     //   26: aload_3
/*      */     //   27: invokestatic 194	dm/jdbc/driver/DmdbCSI:access_server	(Ldm/jdbc/dbaccess/DmMsgSend;Ldm/jdbc/driver/DmdbConnection_bs;)Ldm/jdbc/dbaccess/DmMsgRecv;
/*      */     //   30: astore_2
/*      */     //   31: goto +27 -> 58
/*      */     //   34: astore 4
/*      */     //   36: sipush 6001
/*      */     //   39: invokestatic 95	dm/jdbc/dbaccess/DBError:throwSQLException	(I)V
/*      */     //   42: aload_3
/*      */     //   43: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   46: goto +16 -> 62
/*      */     //   49: astore 5
/*      */     //   51: aload_3
/*      */     //   52: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   55: aload 5
/*      */     //   57: athrow
/*      */     //   58: aload_3
/*      */     //   59: invokevirtual 176	dm/jdbc/driver/DmdbConnection_bs:returnMsg	()V
/*      */     //   62: aload_0
/*      */     //   63: aload_2
/*      */     //   64: invokestatic 755	dm/jdbc/dbaccess/Request_Response:resp_xa_recover	(Ldm/jdbc/xa/DmdbXAResource;Ldm/jdbc/dbaccess/DmMsgRecv;)[Ldm/jdbc/xa/DmdbXid;
/*      */     //   67: areturn
/*      */     // Line number table:
/*      */     //   Java source line #1496	-> byte code offset #0
/*      */     //   Java source line #1497	-> byte code offset #2
/*      */     //   Java source line #1500	-> byte code offset #10
/*      */     //   Java source line #1501	-> byte code offset #16
/*      */     //   Java source line #1502	-> byte code offset #20
/*      */     //   Java source line #1501	-> byte code offset #21
/*      */     //   Java source line #1503	-> byte code offset #24
/*      */     //   Java source line #1504	-> byte code offset #31
/*      */     //   Java source line #1505	-> byte code offset #36
/*      */     //   Java source line #1507	-> byte code offset #42
/*      */     //   Java source line #1506	-> byte code offset #49
/*      */     //   Java source line #1507	-> byte code offset #51
/*      */     //   Java source line #1508	-> byte code offset #55
/*      */     //   Java source line #1507	-> byte code offset #58
/*      */     //   Java source line #1510	-> byte code offset #62
/*      */     // Local variable table:
/*      */     //   start	length	slot	name	signature
/*      */     //   0	68	0	xaResource	dm.jdbc.xa.DmdbXAResource
/*      */     //   0	68	1	flag	int
/*      */     //   1	63	2	recvMsg	DmMsgRecv
/*      */     //   9	50	3	conn	DmdbConnection_bs
/*      */     //   14	11	4	msg	DmMsgSend
/*      */     //   34	3	4	e	IOException
/*      */     //   49	7	5	localObject	Object
/*      */     // Exception table:
/*      */     //   from	to	target	type
/*      */     //   10	31	34	java/io/IOException
/*      */     //   10	42	49	finally
/*      */   }
/*      */ }


/* Location:              D:\Program Files\DBMS_20150813\jdbc\Dm7JdbcDriver17.jar!\dm\jdbc\driver\DmdbCSI.class
 * Java compiler version: 2 (46.0)
 * JD-Core Version:       0.7.1
 */